Staging
v0.8.1
v0.8.1
https://github.com/python/cpython
Revision a5cbab552d294d99fde864306632d7e511a75d3c authored by Thomas Moreau on 16 February 2020, 18:09:26 UTC, committed by GitHub on 16 February 2020, 18:09:26 UTC
As reported initially by @rad-pat in #6084, the following script causes a deadlock. ``` from concurrent.futures import ProcessPoolExecutor class ObjectWithPickleError(): """Triggers a RuntimeError when sending job to the workers""" def __reduce__(self): raise RuntimeError() if __name__ == "__main__": e = ProcessPoolExecutor() f = e.submit(id, ObjectWithPickleError()) e.shutdown(wait=False) f.result() # Deadlock on get ``` This is caused by the fact that the main process is closing communication channels that might be necessary to the `queue_management_thread` later. To avoid this, this PR let the `queue_management_thread` manage all the closing. https://bugs.python.org/issue39104 Automerge-Triggered-By: @pitrou
1 parent 1ed6161
Tip revision: a5cbab552d294d99fde864306632d7e511a75d3c authored by Thomas Moreau on 16 February 2020, 18:09:26 UTC
bpo-39104: Fix hanging ProcessPoolExecutor on shutdown nowait with pickling failure (GH-17670)
bpo-39104: Fix hanging ProcessPoolExecutor on shutdown nowait with pickling failure (GH-17670)
Tip revision: a5cbab5
File | Mode | Size |
---|---|---|
clinic | ||
stringlib | ||
README | -rw-r--r-- | 41 bytes |
abstract.c | -rw-r--r-- | 70.0 KB |
accu.c | -rw-r--r-- | 2.4 KB |
boolobject.c | -rw-r--r-- | 6.6 KB |
bytearrayobject.c | -rw-r--r-- | 70.1 KB |
bytes_methods.c | -rw-r--r-- | 21.2 KB |
bytesobject.c | -rw-r--r-- | 97.3 KB |
call.c | -rw-r--r-- | 28.8 KB |
capsule.c | -rw-r--r-- | 7.3 KB |
cellobject.c | -rw-r--r-- | 5.7 KB |
classobject.c | -rw-r--r-- | 18.0 KB |
codeobject.c | -rw-r--r-- | 34.8 KB |
complexobject.c | -rw-r--r-- | 31.6 KB |
descrobject.c | -rw-r--r-- | 58.3 KB |
dict-common.h | -rw-r--r-- | 2.2 KB |
dictnotes.txt | -rw-r--r-- | 6.0 KB |
dictobject.c | -rw-r--r-- | 140.0 KB |
enumobject.c | -rw-r--r-- | 13.4 KB |
exceptions.c | -rw-r--r-- | 87.2 KB |
fileobject.c | -rw-r--r-- | 16.8 KB |
floatobject.c | -rw-r--r-- | 70.6 KB |
frameobject.c | -rw-r--r-- | 36.8 KB |
funcobject.c | -rw-r--r-- | 31.1 KB |
genobject.c | -rw-r--r-- | 66.2 KB |
interpreteridobject.c | -rw-r--r-- | 8.5 KB |
iterobject.c | -rw-r--r-- | 9.2 KB |
listobject.c | -rw-r--r-- | 97.3 KB |
listsort.txt | -rw-r--r-- | 35.3 KB |
lnotab_notes.txt | -rw-r--r-- | 5.9 KB |
longobject.c | -rw-r--r-- | 173.5 KB |
memoryobject.c | -rw-r--r-- | 91.4 KB |
methodobject.c | -rw-r--r-- | 14.4 KB |
moduleobject.c | -rw-r--r-- | 24.9 KB |
namespaceobject.c | -rw-r--r-- | 7.4 KB |
object.c | -rw-r--r-- | 59.8 KB |
obmalloc.c | -rw-r--r-- | 87.9 KB |
odictobject.c | -rw-r--r-- | 73.1 KB |
picklebufobject.c | -rw-r--r-- | 6.0 KB |
rangeobject.c | -rw-r--r-- | 35.1 KB |
setobject.c | -rw-r--r-- | 73.6 KB |
sliceobject.c | -rw-r--r-- | 19.1 KB |
structseq.c | -rw-r--r-- | 14.7 KB |
tupleobject.c | -rw-r--r-- | 30.9 KB |
typeobject.c | -rw-r--r-- | 249.0 KB |
typeslots.inc | -rw-r--r-- | 3.9 KB |
typeslots.py | -rwxr-xr-x | 1.2 KB |
unicodectype.c | -rw-r--r-- | 7.5 KB |
unicodeobject.c | -rw-r--r-- | 462.4 KB |
unicodetype_db.h | -rw-r--r-- | 246.9 KB |
weakrefobject.c | -rw-r--r-- | 30.9 KB |
Computing file changes ...