(file, barrier)
| 810 | file.write("x") |
| 811 | |
| 812 | def reader(file, barrier): |
| 813 | barrier.wait() |
| 814 | for _ in range(read_count): |
| 815 | for line in file: |
| 816 | self.assertEqual(line, "") |
| 817 | |
| 818 | with self.open(os_helper.TESTFN, "w+") as f: |
| 819 | barrier = threading.Barrier(thread_count + 1) |
no test coverage detected