from concurrent.futures import ThreadPoolExecutor 
import time
a = True  # 設(shè)置全局變量
def fun():  # 線程池執(zhí)行的函數(shù)
    while a:  #  線程池中的循環(huán)代碼，每次循環(huán)都檢查一遍變量a的值
        time.sleep(0.1)  # 線程需要執(zhí)行的具體代碼
        print('1')

tp = ThreadPoolExecutor(5)  # 創(chuàng)建線程池
for i in range(10):
    tp.submit(fun)  # 向線程池提交任務(wù)

time.sleep(1)  
a = False  # 需要結(jié)束線程池任務(wù)時(shí)，執(zhí)行該代碼
tp.shutdown()  # 關(guān)閉線程池

from concurrent.futures import ThreadPoolExecutor
import sys
import time

a = True
def call(): # 定義退出的函數(shù)
    if not a:
        print('線程結(jié)束退出')
        sys.exit()  # 退出

def fun(callback=None):  # 模擬sftp.get方法，循環(huán)執(zhí)行，并且有回調(diào)函數(shù)
    while True:
        time.sleep(0.1)
        print('1')
        if callback != None:
            callback()  # 每次循環(huán)調(diào)用回調(diào)函數(shù)，進(jìn)行判斷是否需要結(jié)束線程

tp = ThreadPoolExecutor(5)
for i in range(10):
    tp.submit(fun, call)

time.sleep(1)
a = False
tp.shutdown()