Function scenario_shared_encoder_shared_dict

tsan_stress_simplejson.py:346–364

All threads encode the SAME dict -> encoder_listencode_dict crit-sect.

()

def scenario_shared_encoder_shared_dict():
    """All threads encode the SAME dict -> encoder_listencode_dict crit-sect."""
    encoder = _make_shared_encoder()
    shared = SHARED_DICT

    def worker():
        deadline = time.monotonic() + DURATION
        for _ in range(ITERATIONS):
            try:
                encoder(shared, 0)
            except Exception:
                pass
            if time.monotonic() > deadline:
                break

    run_scenario(
        "shared encoder + shared dict (encoder_listencode_dict CS)",
        [worker],
    )


def scenario_shared_encoder_shared_list():