Lang added the comment:

# code reproduce bug
# KeyError in lib\multiprocessing\managers.py in incref 

import multiprocessing as mp
from time import sleep

def func(queue):
    pass

if __name__ == '__main__':
    manager = mp.Manager()

    pool = mp.Pool(1)

    queue = manager.Queue()
    r = pool.apply_async(func, args = [queue])
    #sleep(1)
    queue = None

    pool.close()
    pool.join()

----------
nosy: +tlxxzj

_______________________________________
Python tracker <rep...@bugs.python.org>
<https://bugs.python.org/issue31092>
_______________________________________
_______________________________________________
Python-bugs-list mailing list
Unsubscribe: 
https://mail.python.org/mailman/options/python-bugs-list/archive%40mail-archive.com

Reply via email to