diff --git a/Lib/test/test_queue.py b/Lib/test/test_queue.py index 2c04f648434ca2c..b1e37873de98480 100644 --- a/Lib/test/test_queue.py +++ b/Lib/test/test_queue.py @@ -320,10 +320,7 @@ def test_shutdown_immediate_all_methods_in_one_thread(self): def _write_msg_thread(self, q, n, results, i_when_exec_shutdown, event_shutdown, event_start): - # w is used for logging all events of the thread. - w = [threading.get_ident(), "w"] put_atleast = i_when_exec_shutdown//2 - w.append(put_atleast) for i in range(1, n+1): try: q.put((i, "YDLO")) @@ -341,15 +338,9 @@ def _write_msg_thread(self, q, n, results, if not event_shutdown.is_set(): event_shutdown.set() results.append(True) - w.append(True) - - w.extend((f'nbw={i}', "W")) q.join() - w.append("WW") def _read_msg_thread(self, q, results, event_start): - # r is used for logging all events of the thread. - r = [threading.get_ident(), 'r', ] nbr = 0 while True: try: @@ -358,14 +349,10 @@ def _read_msg_thread(self, q, results, event_start): nbr += 1 except self.queue.ShutDown: results.append(True) - r.append(True) break except self.queue.Empty: pass - - r.extend((f'{nbr=}', "R")) q.join() - r.append("RR") def _shutdown_thread(self, q, event_end, immediate): event_end.wait()