当前位置: 首页 > news >正文

关于Thread.start()后的困惑、imap

在for循环中,接着开thread,开完就start,当时有个困惑,就是比如开的一个thread的这个start执行完,但是这个for循环还没执行完,那程序会跑到for循环的后面逻辑吗?

比如下面13行for循环开始开第一个first_thread,并且first_thread也在start,然后这个start结束了,但是for循环还没结束 ,那么程序的逻辑会跑到19行吗?不会的,因为主进程还在for循环跑,线程跑完了,它应该就结束了,它不是主进程。所以会等着for循环执行完,才执行19行。从最后的执行结果就可以看出是等待for循环结束了才执行19行。

import time
from threading import Threaddef count(x, y):c = 0while c < 3:c += 1x += xy += yif __name__ == '__main__':counts = []for x in range(10):thread = Thread(target=count, args=(1, 1))time.sleep(3)print('one')counts.append(thread)thread.start()for thread in counts:print('two')thread.join()

另外join的方法:“This blocks the calling thread until the thread whose join() method is called terminates -- either normally or through an unhandled exception or until the optional timeout occurs.”,我们也看到,一旦线程执行完,其会自动终止,那么couts中记录的每个thread的变量是有一些属性,这些属性记录线程是否执行完,如下图:

所以我之前的困惑是,既然线程执行完,那么counts中记录的变量应该就失效了,对应的其变量调用join()方法应该也调用不了,这么理解其实是错误的。正确的是这些变量还有效,只不过其start()方法已经执行完了。

另外Pool.imap一旦定义了,这个方法会返回一个迭代器,不管这个迭代器有没有在后面使用,只有执行这句的下一句其imap已经开了进程在跑,其结果会写到内存中,需注意内存溢出。

from multiprocessing.pool import ThreadPool, Pooldef count(x):print('start---')return xif __name__ == '__main__':pool = Pool()ret_iter = pool.imap(count, [1])print('test')print('test---')for i in ret_iter:print(i)

从下图打的断点可以看出,其已经在开进程跑了,不过如果直接跑,不debug,那么可能打印顺序不对,因为开的进程跑的速度问题

参考:

  1. https://blog.csdn.net/qq_26460841/article/details/110420572

  1. https://blog.csdn.net/weixin_39765280/article/details/111629605?utm_medium=distribute.pc_relevant.none-task-blog-2~default~baidujs_baidulandingword~default-0-111629605-blog-110420572.pc_relevant_aa&spm=1001.2101.3001.4242.1&utm_relevant_index=3

http://www.lryc.cn/news/26436.html

相关文章:

  • qml学习之qwidget与qml结合使用并调用信号槽交互
  • 【 华为OD机试 2023】 组装新的数组(C++ Java JavaScript Python)
  • 【洛谷 P2089】烤鸡(循环枚举)
  • windows10安装ubantu双系统
  • 【华为OD机试 2023】 人数最多的站点/小火车最多人时所在园区站点(C++ Java JavaScript Python)
  • 2024届暑期实习实录(阿里云大数据研发平台)
  • 空口协议probe req和probe rsp 、auth req和auth rsp 、assoc req和assoc rsp讲解
  • vscode ssh一直卡在wget的解决方案
  • 【Python学习笔记】第二十五节 Python MySQL
  • 折叠屏手机自带的屏幕表面层为什么不能自己撕?
  • 20.hadoop系列之Yarn资源调度器
  • 206页16万字城市运行“一网统管”体系建设项目需求报告
  • 【JS】数组Array的使用
  • 2023年,软件测试怎么样?
  • 【学习笔记】NOMURA Programming Competition 2020
  • iis下常用程序的伪静态规则列表(包括wordpress、thinkphp)
  • 【Python语言基础】——Python Select From
  • 数据增广真有那么神奇吗?
  • 常用基础硬件知识 - 判断MOS管导通
  • 2023金三银四,测试人还能找到好工作吗?
  • c++构造函数
  • redis 未授权访问漏洞
  • 如何制作一个自定义的winpe?
  • QString转为2进制,8进制,10进制,16进制介绍
  • 2023-3-2-22:01随笔
  • 学习红客技术必备,手把手教你成为“安防第一人”
  • Git系列:常见指令辨析
  • 并发编程实战-构建自定义的同步工具
  • HBase集群部署
  • 网络传输:linux下的网络请求和下载(ping wget curl)、端口