multiprocessing Event实现中断进程或程序

参考:https://www.cnblogs.com/MoKinLi/p/17931515.html

import multiprocessing
import time

def worker(event, value):
    while True:
        # 检查事件是否被设置
        if event.is_set():
            # 事件被设置,中断程序
            break

        # 模拟工作
        time.sleep(1)
        print(f"Working: {value}")

if __name__ == "__main__":
    # 创建事件
    event = multiprocessing.Event()

    # 创建子进程
    p = multiprocessing.Process(target=worker, args=(event, "test"))
    p.start()

    # 等待 5 秒
    time.sleep(5)

    # 设置事件
    event.set()

    # 等待子进程结束
    p.join()

    print("程序已中断")

multiprocessing.Process(target=worker, args=(event, “test”))
启动子进程;主进程time.sleep(5)运行,当主进程设置事件 event.set()后子进程被关闭

1)去掉 p.join() 可以让程序继续运行,但子进程可能不会立即终止。

原因:

p.join() 方法会阻塞主进程,直到子进程结束。
如果不调用 p.join(),主进程会继续运行,而子进程会在后台继续运行。

2)主进程设置event.set() 是怎么被子进程识别的
在这里插入图片描述

在这里插入图片描述

相关推荐

  1. 如何让Go程序以后台进程daemon方式运行

    2024-03-09 23:54:01       39 阅读
  2. Python中开启线程进程

    2024-03-09 23:54:01       34 阅读

最近更新

  1. TCP协议是安全的吗?

    2024-03-09 23:54:01       16 阅读
  2. 阿里云服务器执行yum,一直下载docker-ce-stable失败

    2024-03-09 23:54:01       16 阅读
  3. 【Python教程】压缩PDF文件大小

    2024-03-09 23:54:01       15 阅读
  4. 通过文章id递归查询所有评论(xml)

    2024-03-09 23:54:01       18 阅读

热门阅读

  1. Kafka 之 AdminClient 配置

    2024-03-09 23:54:01       21 阅读
  2. 小白跟做江科大51单片机之DS18B02按键控制效果

    2024-03-09 23:54:01       20 阅读
  3. 设计模式 工厂模式

    2024-03-09 23:54:01       24 阅读
  4. MongoDB在业务中的应用

    2024-03-09 23:54:01       23 阅读
  5. LightDB24.1 XMLELEMENT支持省略NAME关键字

    2024-03-09 23:54:01       21 阅读
  6. Android APP启动流程解析

    2024-03-09 23:54:01       22 阅读
  7. 构建智能IoT系统的步骤

    2024-03-09 23:54:01       25 阅读
  8. 云计算之道:学习方法、实践经验与行业展望

    2024-03-09 23:54:01       22 阅读
  9. 错误与异常之为何要异常

    2024-03-09 23:54:01       22 阅读