我不懂python线程

Question

我尝试运行这段代码，其中两个线程应根据计划任务进行初始化。我只想让守护进程并行，在一定时间后打印出一个非特定的全局值。

import os
import schedule
import time
import threading
from threading import Thread

myval = 0
thrs = []

def clear():
    os.system('cls' if os.name=='nt' else 'clear')

def loopfunc(t):
    global myval
    myval = t
    clear()
    print("myval=",t)

def primefunc(t):
    schedule.every(5).to(20).seconds.do(
        loopfunc,t)
    while True:
        schedule.run_pending()
        time.sleep(1)

def main():
    for num in [1,2]:
        thrs.append(Thread(target=primefunc(num)))
        thrs[-1].start()
    print(threading.active_count)

if __name__ == '__main__':
    main()

当尝试如上所述运行它时，只有第一个线程被初始化并循环运行。所以我的输出总是myval=1

当我为目标函数插入lambda 时：

thrs.append(Thread(target=lambda:primefunc(num)))

两个线程都已初始化，但我有随机双输出

myval=2
myval=2

或

myval=1
myval=1

这里发生了什么？ 亲切的问候，MK

Answer 1

第一个问题是因为你在这里直接调用了primefunc函数，而不是把它作为参数传递给Thread。

thrs.append(Thread(target=primefunc(num)))

您需要将其包装在 lambda 中或提供裸函数名称作为目标，并在 Thread 的 args 关键字参数中提供 num 参数，如下所示：

thrs.append(Thread(target=lambda: primefunc(num)))

# or

thrs.append(Thread(target=primefunc, args=[num]))

对于您的输出加倍，我怀疑这里发生的情况是您有两个调度程序循环在不同的线程中同时运行，并且它们在从内部队列中删除之前都选择了相同的job。 The code for scheduler is on github, and you can see that the job runner does not perform any kind of locking around the running of tasks and removing them from the queue to make the two operations atomic together.

以下是可能导致该场景的一系列事件的示例。假设我们的执行时间排在第 7 位，调度程序决定添加loopfunc(1) 的执行。以下是之后可能发生的一系列事件：

1. 线程 1 运行 schedule.run_pending()。
2. 线程 1 在调度程序队列中找到作业 loopfunc(1)。
3. 线程 1 运行 loopfunc(1) 并输出 myval=1
4. 在从队列中删除 loopfunc(1) 之前，会发生到线程 2 的上下文切换。线程 2runs schedule.run_pending()
5. 线程 2 在调度程序队列上找到作业 loopfunc(1)。
6. 线程 2 运行 loopfunc(1) 并输出 myval=1
7. 线程 2 将其从队列中移除。
8. 上下文切换发生回线程 1。
9. 线程 1 尝试从队列中删除 loopfunc(1)，但它不再存在。

还有其他几种可能发生的方式，并且不能保证每次都会发生，但您可以看看如何最终导致myval=1 被打印两次。

我认为这里的解决方案是放弃调度程序，因为它的目的与这里的线程相同。相反，也许只是生成随机数并自己在primefunc 中跟踪时间，例如：

def primefunc(t):
    time = 0
    r = random.randint(5, 20)
    while True:
        if time % r == 0:
            loopfunc(t)
            r = random.randint(5, 20)
        time.sleep(1)
        time += 1

您也可以选择相反的方法，取消线程并保留调度程序。然后你可以在你的 main 函数中运行调度程序循环，它看起来像这样：

def main():
    for num in [1,2]:
        schedule.every(5).to(20).seconds.do(loopfunc,num)
    while True:
        schedule.run_pending()
        time.sleep(1)