Можно ли узнать возврат функции при использовании многопоточности Thread на Python?

Question

[Elick]

Ниже приведен простой пример для понимания.
Подобное выполнение потоков подразумевается использовать в бесконечном цикле. Одна из функций имеет возврат значения, можно ли после завершения ее выполнения как-то достать это значение возврата (подразумевается дальнейшее использование этого значения в следующих итерациях)?

from threading import Thread

def sum_(x, y):
    time.sleep(2)
    return x + y

def mul_(x, y):
    time.sleep(2)
    print(x*y)


x = 5
y = 4

t1 = Thread(target=sum_, args=(x,y))
t2 = Thread(target=mul_, args=(x,y))

t1.start()
t2.start()
t1.join()
t2.join()

Answer 1

[Elick]

from threading import Thread

class ThreadWithResult(Thread):
    def __init__(self, group=None, target=None, name=None, args=(), kwargs={}, *, daemon=None):
        def function():
            self.result = target(*args, **kwargs)
        super().__init__(group=group, target=function, name=name, daemon=daemon)

def sum_(x, y):
    time.sleep(2)
    return x + y

def mul_(x, y):
    time.sleep(2)
    print(x*y)

x = 5
y = 4

t1 = ThreadWithResult(target=sum_, args=(x,y))
t2 = Thread(target=mul_, args=(x,y))

t1.start()
t2.start()
t1.join()
t2.join()
print(t1.result)

Comments

[Elick]

Первоисточник с большим количеством вариантов решения
https://stackoverflow.com/questions/6893968/how-to...

Answer 2

[Vindicar]

Лучше используй долгоживущие потоки и пару queue.Queue. Из первой потоки в цикле извлекают задания и обрабатывают их, во вторую складывают ответы. Главный поток - наоборот, кладёт задания в первую очередь и извлекает ответы из второй.

См. также: паттерн "поставщик-потребитель".