Почему при Queue().get() (multiprocessing) через время зависает программа?

Question

[agent_2203]

Есть код:

def execute(self, function, **args):
        while True:
            tmout = False
            sem.acquire()
            response = Queue()
            p = Process(
                target=self.execute_work, 
                args=[function, response], 
                kwargs=args
            )
            p.start()
            p.join(10)
            if p.is_alive():
                p.terminate()
                p.join()
                tmout = True
            resp = response.get()
            sem.release()
            if tmout:
                continue
            resp = resp if resp != dict else resp.copy()

К этому методу обращаются несколько потоков и через время response.get() просто виснит, с чем это может быть связано, не знаете ?

Answer 1

[Дмитрий]

Потому что это блокирующий вызов.

Queue.get(block=True, timeout=None)

Remove and return an item from the queue. If optional args block is true and timeout is None (the default), block if necessary until an item is available.

Comments

[agent_2203]

Как это в итоге исправить, не подскажите ?

[agent_2203]

Мм, в общем у меня опечатка в коде была, я забыл break поставить в продолжение которое я не выложил, теперь все работает замечательно