时间戳

首页 > 解决方案 > Python：如何等到一个函数在不同的线程中被调用？

python - Python：如何等到一个函数在不同的线程中被调用？

问题描述

我在线程 A 中有一个函数，它需要等到调用线程 B 中的函数。

线程B中的函数是周期性调用的，所以只需要等到下一次调用就可以了。这使我可以与之同步。

我该怎么做？

（对不起，如果这是微不足道的。）

标签： pythonmultithreadingevent-handling

解决方案

没有多线程问题是微不足道的，这可能是计算机科学的一条原则。

有多种方法可以做到这一点，但最简单的方法之一是使用 threading.Event 对象。事件是所谓的同步原语中最简单的。有关更多想法，请参阅 threading 模块的手册部分。这是一个工作示例：

#! python3.8

import threading
import time

t0 = time.time()

def elapsed_time():
    return time.time() - t0

class StopMe:
    def __init__(self):
        self.running = True

def main():
    ev1 = threading.Event()
    stop = StopMe()
    th1 = threading.Thread(target=thread1, args=(ev1, stop))
    th1.start()
    for _ in range(10):
        ev1.wait()
        print("The function was just called", elapsed_time())
        ev1.clear()
    stop.running = False
    th1.join()
    print("Exit", elapsed_time())

def thread1(event, stop):
    def a_function():
        event.set()
        print("I am the function", elapsed_time())

    while stop.running:
        time.sleep(1.0)
        a_function()

main()

输出：

I am the function 1.0116908550262451
The function was just called 1.0116908550262451
I am the function 2.0219264030456543
The function was just called 2.0219264030456543
I am the function 3.0322916507720947
The function was just called 3.0322916507720947
I am the function 4.033170938491821
The function was just called 4.033170938491821
I am the function 5.043376445770264
The function was just called 5.043376445770264
I am the function 6.043909788131714
The function was just called 6.043909788131714
I am the function 7.054021596908569
The function was just called 7.054021596908569
I am the function 8.06399941444397
The function was just called 8.06399941444397
I am the function 9.064924716949463
The function was just called 9.064924716949463
I am the function 10.066757678985596
The function was just called 10.066757678985596
I am the function 11.076870918273926
Exit 11.076870918273926

这里需要注意的一些事项：

将同步原语放入代码后，您需要考虑如何优雅地终止线程，以及如何整体终止应用程序。在此示例中，线程通过小“StopMe”对象和事件对象进行通信。请注意，主线程可能需要等待一秒钟，直到辅助线程完成其睡眠功能。如果 thread1 在主线程调用连接函数之前开始其时间延迟，则会发生这种情况。这在我的测试运行中没有发生，但它可能会发生，这取决于 CPU 时间片是如何分配给不同线程的。如果这对您来说是不可接受的，那么您必须编写更多代码来解决它。

另请注意，函数调用 ev1.wait() 将阻塞主线程，直到从辅助线程设置事件。在不是您想要的 GUI 应用程序中。

我使用 Python3.8 运行它，但该程序不使用任何特定于版本的功能，因此它应该与任何合理的最新 Python 版本相同。

推荐阅读