Skip to content

Commit

Permalink
Remove logs
Browse files Browse the repository at this point in the history
  • Loading branch information
YvesDup committed Feb 25, 2024
1 parent bf5dab2 commit fff5548
Showing 1 changed file with 0 additions and 13 deletions.
13 changes: 0 additions & 13 deletions Lib/test/test_queue.py
Original file line number Diff line number Diff line change
Expand Up @@ -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"))
Expand All @@ -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:
Expand All @@ -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()
Expand Down

0 comments on commit fff5548

Please sign in to comment.