Python Multiprocess не заканчивается

Question

Я новичок в многопроцессе python, и я хочу понять, почему мой код не заканчивается (возможно, зомби или тупик) и как его исправить. Функции createChain также выполняют цикл for и возвращают кортеж: (value1, value2). Внутри функции createChain есть другие вызовы для других функций. Я не думаю, что размещение кода функции createChain поможет, потому что внутри этой функции я ничего не делаю в отношении многопроцессорности. Я пытался сделать процессы как деамон, но все равно не работал. Странно думать, что если я уменьшу значение maxChains i.e до 500 или 100 работает.

Я просто хочу, чтобы процесс выполнял тяжелые задачи и помещал результаты в тип данных.

Моя версия питона 2,7

def createTable(chainsPerCore, q, chainLength): 

    for chain in xrange(chainsPerCore): 
     q.put(createChain(chainLength, chain)) 


def initTable(): 
    maxChains = 1000 
    chainLength = 10000 
    resultsQueue = JoinableQueue() 
    numOfCores = cpu_count() 
    chainsPerCore = maxChains/numOfCores 

    processes = [Process(target=createTable, args=(chainsPerCore, resultsQueue, chainLength,)) for x in range(numOfCores)] 

    for p in processes: 
     # p.daemon = True 
     p.start() 

    # Wait for hashing cores to finish 
    for p in processes: 
     p.join() 

    resultsQueue.task_done() 

    temp = [resultsQueue.get() for p in processes] 
    print temp 

Answer 1

Основываясь на очень полезные комментарии Tadhg Макдональд-Jensen я понял, лучше мои потребности и как Очереди разработки и для какой цели они должны быть использованы.

я изменить свой код

def initTable(output): 
    maxChains = 1000 

    results = [] 

    with closing(Pool(processes=8)) as pool: 
     results = pool.map(createChain, xrange(maxChains)) 
     pool.terminate()