判断Threading.start新线程是否执行完毕的实例
新写自己的Threading类
class MyThread(threading.Thread):#我的Thread类 判断流程结束没 用于os shell命令是否执行判断 def __init__(self,func = ""):#输入待执行函数名 我执行的函数没有参数就没有加args输入了 threading.Thread.__init__(self) self.func = func self.result = 1#未完成为1 标志位 # 调用start自动执行的函数 def run(self): self.result = self.func() self.result = 0#完成返回0
然后执行
class MyThread(threading.Thread):#我的Thread类 判断流程结束没 用于os shell命令是否执行判断 def __init__(self,func = ""):#输入待执行函数名 我执行的函数没有参数就没有加args输入了 threading.Thread.__init__(self) self.func = func self.result = 1#未完成为1 标志位 # 调用start自动执行的函数 def run(self): self.result = self.func() self.result = 0#完成返回0
这样就可以判断os.sysytem里语句是否执行完成是否
补充知识：python的threading.Thread线程的start、run、join、setDaemon
Pycharm整体看下Thread类的内容：模拟的是Java的线程模型
表示方法method，上面的锁头表示这个是类内部的方法，从方法名字命名规范可以看出，都是_和__开头的，一个下划线表示是子类可以继承，两个下划线表示是只有Thread内部可以访问，子类都不可以访问。
表示property，可以使用类直接访问：Thread._block
表示field，就是self.x定义的东东
表示变量variable
name/getName/setName是线程名字有关的；
isDaemon是否是守护进程
setDaemon设置为守护进程，如果把调用线程设置为守护线程，那么等调用线程结束后，被调用的子线程结束与否都会随着守护线程结束
isAlive线程是否是活动状态
start方法开启一个新线程。把需要并行处理的代码放在run()方法中，start()方法启动线程将自动调用 run()方法。
run线程实际在运行的内容，可以被子类继承和重写overide。
join阻塞调用它的线程，直到等待被调用的线程运行结束，其实就变成了单线程。参数timeout的作用是，当前线程等待被调用的子线程的时间，如果时间到了，不管子线程是否结束，当前线程都进入就绪状态，重新等待CPU调度。
Join方法的Java示例：
新建一个Thread类，重写run()方法：
public class MyThread extends Thread {
@Override
public void run() {
System.out.println("子线程执行完毕");
}
}
新建测试类，测试Join()方法：
public class TestThread {
public static void main(String[] args) {
//循环五次
for (int i = 0; i < 5; i++) {
MyThread thread = new MyThread();
//启动线程
thread.start();
try {
//调用join()方法
thread.join();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("主线程执行完毕");
System.out.println("~~~~~~~~~~~~~~~");
}
}
}
输出结果如下：
子线程执行完毕 主线程执行完毕 ~~~~~~~~~~~~~~~ 子线程执行完毕 主线程执行完毕 ~~~~~~~~~~~~~~~ 子线程执行完毕 主线程执行完毕 ~~~~~~~~~~~~~~~ 子线程执行完毕 主线程执行完毕 ~~~~~~~~~~~~~~~ 子线程执行完毕 主线程执行完毕 ~~~~~~~~~~~~~~~
结果分析： 子线程每次都在主线程之前执行完毕，即子线程会在主线程之前执行。
什么时候用join()方法？
在很多情况下，主线程生成并起动了子线程，如果子线程里要进行大量的耗时的运算，主线程往往将于子线程之前结束，但是如果主线程处理完其他的事务后，需要用到子线程的处理结果，也就是主线程需要等待子线程执行完成之后再结束，这个时候就要用到join()方法了。
用start方法来启动线程，真正实现了多线程运行，这时无需等待run方法体代码执行完毕而直接继续执行下面的代码。通过调用Thread类的start()方法来启动一个线程，这时此线程处于就绪（可运行）状态，并没有运行，一旦得到cpu时间片，就开始执行run()方法，这里方法 run()称为线程体，它包含了要执行的这个线程的内容，run方法运行结束，此线程随即终止。
run()方法只是类的一个普通方法而已，如果直接调用Run方法，程序中依然只有主线程这一个线程，其程序执行路径还是只有一条，还是要顺序执行，还是要等待run方法体执行完毕后才可继续执行下面的代码，这样就没有达到写线程的目的。
总结：调用start方法方可启动线程，而run方法只是thread的一个普通方法调用，还是在主线程里执行。把需要并行处理的代码放在run()方法中，start()方法启动线程将自动调用 run()方法
可见join和setDaemon作用是相反的，一个是等待子线程结束，一个是不等到子线程结束，有可能把子线程强制结束。如果两个都不设置的时候，那么主线程和子线程各自运行各自的，互不干扰，谁结束都不会影响另一个运行情况：见https://www.jb51.net/article/185872.htm示例
以上这篇判断Threading.start新线程是否执行完毕的实例就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持我们。
相关推荐
-
python中的线程threading.Thread()使用详解
1. 线程的概念: 线程,有时被称为轻量级进程(Lightweight Process,LWP),是程序执行流的最小单元.一个标准的线程由线程ID,当前指令指针(PC),寄存器集合和堆栈组成.另外,线程是进程中的一个实体,是被系统独立调度和分派的基本单位,线程自己不拥有系统资源,只拥有一点儿在运行中必不可少的资源,但它可与同属一个进程的其它线程共享进程所拥有的全部资源. 2. threading.thread()的简单使用 2.1 python的thread模块是比较底层的模块,python的t
-
python中threading开启关闭线程操作
在python中启动和关闭线程: 首先导入threading import threading 然后定义一个方法 def serial_read(): ... ... 然后定义线程,target指向要执行的方法 myThread = threading.Thread(target=serial_read) 启动它 myThread.start() 二.停止线程 不多说了直接上代码 import inspect import ctypes def _async_raise(tid, exctype
-
python 在threading中如何处理主进程和子线程的关系
之前用python的多线程,总是处理不好进程和线程之间的关系.后来发现了join和setDaemon函数,才终于弄明白.下面总结一下. 1.使用join函数后,主进程会在调用join的地方等待子线程结束,然后才接着往下执行. join使用实例如下: import time import random import threading class worker(threading.Thread): def __init__(self): threading.Thread.__init__(self
-
判断Threading.start新线程是否执行完毕的实例
新写自己的Threading类 class MyThread(threading.Thread):#我的Thread类 判断流程结束没 用于os shell命令是否执行判断 def __init__(self,func = ""):#输入待执行函数名 我执行的函数没有参数就没有加args输入了 threading.Thread.__init__(self) self.func = func self.result = 1#未完成为1 标志位 # 调用start自动执行的函数 def r
-
Java判断线程池线程是否执行完毕
在使用多线程的时候有时候我们会使用 java.util.concurrent.Executors的线程池,当多个线程异步执行的时候,我们往往不好判断是否线程池中所有的子线程都已经执行完毕,但有时候这种判断却很有用,例如我有个方法的功能是往一个文件异步地写入内容,我需要在所有的子线程写入完毕后在文件末尾写"---END---"及关闭文件流等,这个时候我就需要某个标志位可以告诉我是否线程池中所有的子线程都已经执行完毕,我使用这种方式来判断. public class MySemaphore
-
Java 判断线程池所有任务是否执行完毕的操作
我就废话不多说了,大家还是直接看代码吧~ import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class Test { public static void main(String args[]) throws InterruptedException { ExecutorService exe = Executors.newFixedThreadPool(3); f
-
Python多线程Threading、子线程与守护线程实例详解
本文实例讲述了Python多线程Threading.子线程与守护线程.分享给大家供大家参考,具体如下: 线程与进程: 线程对于进程来说,就好似工厂里的工人,分配资源是分配到工厂,工人再去处理. 线程是被系统独立调度和分派的基本单位,线程自己不拥有系统资源,只拥有一点儿在运行中必不可少的资源,但它可与同属一个进程的其它线程共享进程所拥有的全部资源. 在单个程序中同时运行多个线程完成不同的工作,称为多线程 对于IO密集型的程序来说,多线程可以利用读IO的时间去做其他事[IO并不占用CPU,这就好像A
-
spring boot使用自定义配置的线程池执行Async异步任务
在前面的博客中,http://www.jb51.net/article/106718.htm 我们使用了spring boot的异步操作,当时,我们使用的是默认的线程池,但是,如果我们想根据项目来定制自己的线程池了,下面就来说说,如何定制线程池! 一.增加配置属性类 package com.chhliu.springboot.async.configuration; import org.springframework.boot.context.properties.ConfigurationP
-
spring boot使用自定义的线程池执行Async任务
在前面的博客中,//www.jb51.net/article/134866.htm 我们使用了spring boot的异步操作,当时,我们使用的是默认的线程池,但是,如果我们想根据项目来定制自己的线程池了,下面就来说说,如何定制线程池! 一.增加配置属性类 package com.chhliu.springboot.async.configuration; import org.springframework.boot.context.properties.ConfigurationProper
-
spring boot使用自定义配置的线程池执行Async异步任务
目录 一.增加配置属性类 二.创建线程池 三.在主类中开启配置支持 四.测试类 五.测试 六.配置默认的线程池 在前面的博客中,//www.jb51.net/article/106718.htm 我们使用了spring boot的异步操作,当时,我们使用的是默认的线程池,但是,如果我们想根据项目来定制自己的线程池了,下面就来说说,如何定制线程池! 一.增加配置属性类 package com.chhliu.springboot.async.configuration; import org.spr
-
Java 线程池详解及实例代码
线程池的技术背景 在面向对象编程中,创建和销毁对象是很费时间的,因为创建一个对象要获取内存资源或者其它更多资源.在Java中更是如此,虚拟机将试图跟踪每一个对象,以便能够在对象销毁后进行垃圾回收. 所以提高服务程序效率的一个手段就是尽可能减少创建和销毁对象的次数,特别是一些很耗资源的对象创建和销毁.如何利用已有对象来服务就是一个需要解决的关键问题,其实这就是一些"池化资源"技术产生的原因. 例如Android中常见到的很多通用组件一般都离不开"池"的概念,如各种图片
-
java 线程方法join简单用法实例总结
本文实例讲述了java 线程方法join简单用法.分享给大家供大家参考,具体如下: 虽然关于讨论线程join方法的博客已经很多了,不过个人感觉挺多都讨论得不够全面,所以我觉得有必要对其进行一个全面的总结. 一.作用 Thread类中的join方法的主要作用就是同步,它可以使得线程之间的并行执行变为串行执行.具体看代码: public class JoinTest { public static void main(String [] args) throws InterruptedExcepti
-
Java多线程--让主线程等待所有子线程执行完毕在执行
朋友让我帮忙写个程序从文本文档中导入数据到oracle数据库中,技术上没有什么难度,文档的格式都是固定的只要对应数据库中的字段解析就行了,关键在于性能. 数据量很大百万条记录,因此考虑到要用多线程并发执行,在写的过程中又遇到问题,我想统计所有子进程执行完毕总共的耗时,在第一个子进程创建前记录当前时间用System.currentTimeMillis()在最后一个子进程结束后记录当前时间,两次一减得到的时间差即为总共的用时,代码如下 long tStart = System.currentTime