(num)
| 342 | cvar = contextvars.ContextVar('cvar') |
| 343 | |
| 344 | def sub(num): |
| 345 | for i in range(10): |
| 346 | cvar.set(num + i) |
| 347 | time.sleep(random.uniform(0.001, 0.05)) |
| 348 | self.assertEqual(cvar.get(), num + i) |
| 349 | return num |
| 350 | |
| 351 | tp = concurrent.futures.ThreadPoolExecutor(max_workers=10) |
| 352 | try: |