(file, barrier)
| 1093 | file.write("x") |
| 1094 | |
| 1095 | def reader(file, barrier): |
| 1096 | barrier.wait() |
| 1097 | for _ in range(read_count): |
| 1098 | for line in file: |
| 1099 | self.assertEqual(line, "") |
| 1100 | |
| 1101 | with self.open(os_helper.TESTFN, "w+") as f: |
| 1102 | barrier = threading.Barrier(thread_count + 1) |
no test coverage detected