We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 78241a8 commit 52285a2Copy full SHA for 52285a2
Lib/test/test_free_threading/test_set.py
@@ -214,8 +214,7 @@ def reader():
214
215
def test_iternext_concurrent_exhaust_race(self):
216
NUM_LOOPS = 20_000
217
- number_of_threads = 3
218
- barrier = Barrier(number_of_threads)
+ barrier = Barrier(3)
219
box = {"it": None}
220
221
def advancer():
@@ -236,7 +235,11 @@ def producer():
236
235
barrier.wait()
237
238
239
- threads = [Thread(target=advancer) for _ in range(number_of_threads)]
+ threads = [
+ Thread(target=advancer),
240
241
+ Thread(target=producer),
242
+ ]
243
for t in threads:
244
t.start()
245
0 commit comments