ThreadPoolExecutor: передача аргументов / параметров в активные потоки - PullRequest
Новая
       6

ThreadPoolExecutor: передача аргументов / параметров в активные потоки

0 голосов
/ 22 января 2020

Мне было интересно, можно ли посылать аргументы / параметры в активные потоки. Например, я хочу, чтобы функция l oop продолжала работать в отдельном потоке до тех пор, пока command = false не будет вызвана в основном потоке: 

#EXAMPLE
import time
from concurrent.futures import ThreadPoolExecutor
pool = ThreadPoolExecutor(max_workers=2)

def loop(command):
   while command == True:
       print("I won't stop until command is false!!")   


command = True
pool.submit(loop,command)
time.sleep(5)
command = False
pool.submit(loop,command) #<-- THIS STOPS THE LOOP FUNCTION
...