Function wrapper

tsan_stress_simplejson.py:272–280

(fn)

    errors_lock = threading.Lock()

    def wrapper(fn):
        def wrapped():
            try:
                barrier.wait()
                fn()
            except Exception as exc:
                with errors_lock:
                    errors.append(repr(exc))
        return wrapped

    threads = []
    for fn, count in zip(target_fns, thread_counts):