Skip to content

Commit ca28541

Browse files
committed
Address "./python -m test test_interpreters test_concurrent_futures.test_interpreter_pool"
1 parent fcb3385 commit ca28541

File tree

2 files changed

+14
-1
lines changed

2 files changed

+14
-1
lines changed

Lib/concurrent/interpreters/_crossinterp.py

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -68,6 +68,17 @@ def __repr__(self):
6868
return f'{self._MODULE}.{self._NAME}'
6969
# return f'interpreters._queues.UNBOUND'
7070

71+
def __hash__(self):
72+
return hash((self._NAME, self._MODULE))
73+
74+
def __reduce__(self):
75+
return self._NAME
76+
77+
def __eq__(self, other):
78+
if other is self:
79+
return True
80+
return repr(other) == repr(self)
81+
7182

7283
UNBOUND = object.__new__(UnboundItem)
7384
UNBOUND_ERROR = object()

Lib/test/test_concurrent_futures/test_interpreter_pool.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -425,7 +425,9 @@ def run(taskid, ready, blocker):
425425
for _ in range(pending):
426426
try:
427427
ready.get(timeout=1) # blocking
428-
except interpreters.QueueEmpty:
428+
except interpreters.QueueEmpty :
429+
pass
430+
except queues.QueueEmpty:
429431
pass
430432
else:
431433
done += 1

0 commit comments

Comments
 (0)