Тема не помещается в очередь - PullRequest
Новая
       7

Тема не помещается в очередь

0 голосов
/ 30 сентября 2018

Я пытаюсь создать несколько потоков, ожидающих time.sleep, и поместить случайное число в очередь.А затем получить эти числа из очереди и разделить их на 10000.

Но это не работает, когда time.sleep равен 0, случайное число правильно вставляется в очередь, однако, при времени.сон больше 0, в эту очередь ничего не помещается. 

import random
import time
import os
from threading import Thread
from multiprocessing import Process, Queue

class Tempo(Thread):

    def __init__ (self, queue):
            Thread.__init__(self)
            self._queue = queue

    def run (self):
            temporisation = random.randrange(0,4)
            time.sleep(temporisation)
            rand_range = random.randrange(0,1000)
            self._queue.put(rand_range)
            os.sys.stdout.write(str(rand_range) + " : time sleep : " + str(temporisation) + " put in queue\n")
            os.sys.stdout.flush()

def tempo_x(range_haute, queue):
    for x in range(0,range_haute):
            Tempo(queue).start()
    queue.put('exit')

def divise_10000(queue):
    time.sleep(5)
    while True:
            rand_range = queue.get()
            if isinstance(rand_range, int):
                    os.sys.stdout.write(str(rand_range/10000) + "\n")
                    os.sys.stdout.flush()
            else:
                    break

if __name__ == '__main__':

    queue = Queue()

    get_process = Process(target=divise_10000, args=((queue),))
    get_process.daemon = True
    get_process.start()

    tempo_x(10, queue)

    get_process.join()

Вывод: 

230 : time sleep : 0 put in queue
92 : time sleep : 0 put in queue
763 : time sleep : 0 put in queue
881 : time sleep : 0 put in queue
213 : time sleep : 1 put in queue
124 : time sleep : 1 put in queue
584 : time sleep : 1 put in queue
57 : time sleep : 2 put in queue
583 : time sleep : 2 put in queue
735 : time sleep : 3 put in queue
0.023
0.0092
0.0763
0.0881

Чего мне здесь не хватает?

...