主页 / 问题 / 1088634
Accepted
Brain Drill
Asked:2020-02-28 21:04:51 +0800 CST2020-02-28 21:04:51 +0800 CST

如何在循环执行期间更改线程目标

  • 772

有以下示例：

import threading
from queue import Queue


def myfunc():
    while True:
        num = queue.get()
        print(num / 10)
        queue.task_done()

def myfunc2():
    while True:
        num = queue.get()
        print(num * 10)
        queue.task_done()


queue = Queue()
for t in range(3):
    t = threading.Thread(target=myfunc)
    t.setDaemon(True)
    t.start()
mylist = []
for x in range(10):
    for i in range(10):
        for i in range (10):
            mylist.append(i)
    for i in mylist:
        queue.put(i)
    queue.join()

在这种情况下，如何在循环执行期间将线程的目标更改为myfunc2？

python

2 个回答

  1. Best Answer

    与上一个问题一样，我建议使用线程池而不是自己创建一个。

    import time
import threading
from concurrent.futures.thread import ThreadPoolExecutor

DELAY = 2
COUNT_THREAD = 3

def myfunc(value):
    time.sleep(DELAY)
    print(value, value / 10, threading.current_thread().name)

def myfunc2(value):
    time.sleep(DELAY)
    print(value, value * 10, threading.current_thread().name)


executor = ThreadPoolExecutor(COUNT_THREAD)
for x in range(10):
    for f in (myfunc, myfunc2):
        executor.submit(f, x)
    • 2

  2. 我认为这段代码会对你有所帮助。它应该用来代替你的循环for t in range(3)

    func=myfunc
for i in range(3):
    if i==3:
        func=myfunc2
    t = threading.Thread(target=func)
    t.setDaemon(True)
    t.start()
    • 1

相关问题