python中如何实现“A线程执行,B线程就执行,A停止,B就停止”?

发布于 2022-08-26 17:33:32 字数 245 浏览 15 评论 0

在一个方法中,需要开启两个线程执行一段代码,A,B两个线程的执行过程RT所示,请问在python中如何实现这个场景?麻烦各位大虾大致说一下实现过程。谢谢。

或者,不使用线程,如何使用其他通信方式来实现?


好吧,我自己想了一个比较简单的办法:

flag=1 B执行 A执行

其中B的实现为: while: 若flag=1,执行; 否则退出循环

A实现: 执行; flag=0

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(3

活雷疯 2022-09-02 17:33:32

不知道你的「执行」和「停止」的粒度有多大,或者是一个什么样的场景。

如果 A 和 B 是在一个循环中执行一个个任务的话,那么 B 在每个任务执行前判断 A 是否还活着就可以了。

如果不是这样,并且你要求 A 退出时 B 一定要退出的话,如果 A 是主线程,B 可以设置成 daemon = True 的线程,这样主线程退出时 B 会被强制退出。

否则的话,可能只能用 Python 3.3 提供的杀线程的接口了。

你也可以用多进程的方式,A 在执行时开个进程执行 B,退出前把它杀掉。

一向肩并 2022-09-02 17:33:32

这个可以利用threading.Condition(),然后使用生产消费的方式来实现

# encoding: UTF-8
import threading
import time
con = threading.Condition()
product=None

def produce():
    global product
    while True:
        if con.acquire():
            if not product:
                product='add new'
                print 'produce'
                time.sleep(3)
                con.notify()           
        con.wait()
def consume():
    global product
    while True:
        if con.acquire():
            if product:
                print 'consume'
                product=None
                con.notify()
            con.wait()

t1 = threading.Thread(target=produce)
t2 = threading.Thread(target=consume)
t1.start()
t2.start()
你丑哭了我 2022-09-02 17:33:32

你的办法太粗糙了,而且真的实现起来也是错的。

在C或者其他语言里可以用mutex来实现,但是CPython的GIL限制了两个线程不能同时运行,所以还是洗洗睡吧……

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文