python多线程join方法（python线程 问题请教，怎么保证子线程执行完毕）

本文目录

• python线程 问题请教，怎么保证子线程执行完毕
• Python中threading的join和setDaemon的区别及用法
• Python threading 中join()的作用
• python threading 一定要 join 吗
• 多线程和队列
• Python 类中的方法如何多线程调用

python线程 问题请教，怎么保证子线程执行完毕

首先子线程必须由主线程启动，所以严格意义上的“子线程结束后再执行主线程”是不可能实现，你的意思应该是：主线程创建完子线程后，等待子线程退出，在继续执行。 你的代码基本没有多大问题，只是 Join 方法位置放置不对。 thread1.Start(); // 先启动所有子线程 thread2.Start(); thread3.Start(); thread4.Start(); thread5.Start(); thread1.Join(); // 然后在等待子线程退出 thread2.Join(); thread3.Join(); thread4.Join(); thread5.Join(); 你先前的代码： thread1.Start(); // 线程1 启动 thread1.Join(); // 等待 线程1 退出，线程1 未退出前，后面代码无法执行 thread2.Start(); // 以下代码，均同上所述。 thread2.Join(); thread3.Start(); thread3.Join(); thread4.Start(); thread4.Join();

Python中threading的join和setDaemon的区别及用法

　　python中得thread的一些机制和C/C++不同：在C/C++中，主线程结束后，其子线程会默认被主线程kill掉。而在python中，主线程结束后，会默认等待子线程结束后，主线程才退出。
　　python对于thread的管理中有两个函数：join和setDaemon
　　join：如在一个线程B中调用threada.join()，则threada结束后，线程B才会接着threada.join()往后运行。
　　setDaemon：主线程A启动了子线程B，调用b.setDaemaon(True)，则主线程结束时，会把子线程B也杀死，与C/C++中得默认效果是一样的。
在这里给出一个例子：
#! /usr/bin/env python
import threading
import time

class myThread(threading.Thread):
def __init__(self, threadname):
threading.Thread.__init__(self, name=threadname)
self.st = 2

def run(self):
time.sleep(self.st)
print self.getName()
def setSt(self, t):
self.st = t

def fun1():
t1.start()
print "fun1 done"

def fun2():
t2.start()
print "fun2 done"

t1=myThread("t1")
t2=myThread("t2")
t2.setSt(10);
# t2.setDaemon(True)
fun1()
fun2()
print "now u will see me"

Python threading 中join()的作用

Python中join()的作用：（菜鸟网络） join(): 等待至线程中止。这阻塞调用线程直至线程的join() 方法被调用中止-正常退出或者抛出未处理的异常-或者是可选的超时发生
看着定义大致明白，但是自己确不好理解。主要的功能就是多线程的线程独占，让此时只有一个线程运行。

1.子线程为什么需要join？
join阻塞主线程，可以让主线程获得子线程的处理结果。
如果没有join，由于子线程sleep，尚未append到tmp_list，例子中print tmp_list为空列表，join后即能在append执行后print出来。
如果不需要子线程的处理结果，那么可以不join，当然join了也没啥影响。
2.为什么要写成for循环join的形式？
这个在上文方式二中即提出了，可以即让子线程异步执行，又让主线程等待结果。

python threading 一定要 join 吗

Join的作用是众所周知的，阻塞进程直到线程执行完毕。通用的做法是我们启动一批线程，最后join这些线程结束，例如：

    for i in range(10):
        t = ThreadTest(i)
        thread_arr.append(t)
    for i in range(10):
        thread_arr.start()
    for i in range(10):
        thread_arr.join()

此处join的原理就是依次检验线程池中的线程是否结束，没有结束就阻塞直到线程结束，如果结束则跳转执行下一个线程的join函数。

而py的join函数还有一个特殊的功能就是可以设置超时，如下：

Thread.join()

Wait until the thread terminates. 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.

也就是通过传给join一个参数来设置超时，也就是超过指定时间join就不在阻塞进程。而在实际应用测试的时候发现并不是所有的线程在超时时间内都结束的，而是顺序执行检验是否在time_out时间内超时，例如，超时时间设置成2s，前面一个线程在没有完成的情况下，后面线程执行join会从上一个线程结束时间起再设置2s的超时。

多线程和队列

1、python提供两种方式使用多线程：一个是基于函数：_thread模块或者threading模块。一个是基于类：theading.Thread

使用多线程函数包装线程对象：_thread

_thead.start_new_thead(func,*args,**kwargs)

args,**kwargs是被包装函数的入参，必须传入元祖或字典
使用多线程函数包装线程对象：threading

threading._start_new_thread(func,*args,**kwargs)：开启线程，带元祖或字典

threading.currentThread()：返回当前线程变量

threading.enumerate()：正在运行的线程列表，不含未启动和已结束线程

threading.activeCount()：返回正在运行的线程数量

threading.settrace(func)：为所有threading模块启动的线程设置追踪函数，在调用run方法之前，func会被传给追踪函数

threading.setprofile(func)：为所有threading模块启动的线程设置性能测试函数，也是在run方法调用前就传递给性能测试函数
使用多线程类包装线程对象：threading.Thread

Thread类提供以下方法：

run()：表示线程活动的方法，线程需要控制些什么活动都在这里面定义。当线程对象一但被创建，其活动一定会因调用线程的 start() 方法开始。这会在独立的控制线程调用 run() 方法。

start()：开启线程活动

join()：等待线程中止，阻塞当前线程直到被调用join方法的线程中止。线程A调用线程B的join方法，那线程A将会被阻塞至线程B中止。

isAlive()：返回线程是否还活动

getName()：获取线程名字

setName()：设置线程名字

Lock对象：实例化线程锁，包含acquire方法获取锁 和 release 方法释放锁，在最开始创建锁的时候，锁为未锁定状态，调用acquire方法后锁置为锁定状态，此时其他线程再调用acquire方法就将会被阻塞至其他线程调用release方法释放锁，如果释放一个并未被锁定的锁将会抛出异常。支持上下文管理协议，直接with lock 无需调用锁定，释放方法

Rlock对象：重入锁，相比lock增加了线程和递归的概念。比如：线程目标函数F，在获得锁之后执行函数G，但函数G也需要先获得锁，此时同一线程，F获得锁，G等待，F等待G执行，就造成了死锁，此时使用rlock可避免。一旦线程获得了重入锁，同一个线程再次获取它将不阻塞；但线程必须在每次获取它时释放一次。

daemon属性：设置该线程是否是守护线程，默认为none，需要在调用start方法之前设置好

事件对象：一个线程发出事件信号 ，其他线程收到信号后作出对应活动。实例化事件对象后，初始事件标志为flase。调用其wait方法将阻塞当前所属线程，至事件标志为true时。调用set方法可将事件标志置为true，被阻塞的线程将被执行。调用clear方法可将事件标志置为flase

注意点：

1、继承threading.Thread类，初始化时要记得继承父类的__init__方法

2、run()方法只能有一个入参，故尽量把启动线程时的参数入参到初始化的时候

3、锁要设定全局的，一个子线程获得一个锁没有意义

以下实例：有一个列表，线程A从尾到头遍历元素，线程B从头到尾将元素值重置为1，设置线程锁之前线程A遍历到头部的数据已经被修改，设置线程锁之后不会再有数据不一致的情况

import threading,time

class tt(threading.Thread):

    def __init__(self,name,func,ll):

        threading.Thread.__init__(self) #继承父级的初始化方法

        self.name=name

        self.func=func  #run方法只能带一个入参，故把方法入参到初始化的时候

        self.ll=ll

    def run(self):

        print(self.name)

        threadlock.acquire() #获得锁

        self.func(self.ll)

        threadlock.release() #释放锁

def readd(x):

    a=len(x)

    while a》0:

        print(x)

        a-=1

def sett(x):

    for i in range(len(x)):

        x=1

    print(x)

if __name__=="__main__":

    l =

    threadlock=threading.Lock() #实例化全局锁

    th1=tt("read",readd,l)

    th3=tt("set",sett,l)

    th1.start()

    th3.start()

    th_list= 

    th_list.append(th1)

    th_list.append(th3)

    for li in th_list:

        li.join()        #主线程被阻塞，直到两个子线程处理结束

    print("主线程结束")

2、队列

queue模块包含queue.Queue(maxsize=0)先入先出队列，queue.LifoQueue()先入后出队列，和queue.PriorityQueue()优先级可设置的队列

Queue 模块中的常用方法:

Queue.qsize() 返回队列的大小，获取的数据不可靠，因为一直有线程在操作队列，数据一直变化

Queue.empty() 如果队列为空，返回True,反之False

Queue.full() 如果队列满了，返回True,反之False

Queue.full 与 maxsize 大小对应

Queue.put(block=true,timeout=none) 将item数据写入队列，block=True，设置线程是否阻塞，设置阻塞当队列数据满了之后就会阻塞，一直到队列数据不满时继续添加，如果设置不阻塞，当队列满了就会一直到timeout到后报错

Queue.get() 取出队列数据，block=True，设置线程是否阻塞。设置阻塞，将会等待直到队列不为空有数据可取出，设置不阻塞直到超过timeout等待时间后报错

Queue.task_done() 在完成一项工作之后，Queue.task_done()函数向任务已经完成的队列发送一个信号

Queue.join() 实际上意味着等到队列为空，再执行别的操作。会在队列有未完成时阻塞，等待队列无未完成的任务，取出数据get()之后还需要配置task_done使用才能让等待队列数-1

import queue,time

import threading

q=queue.Queue(maxsize=5)

def sett():

    a=0

    while a《20:

        q.put(a,True)

        print("%d被put"%a)

        a+=1

def gett():

    time.sleep(1)

    while not q.empty(): #只要队列没空，一直取数据

        print("%d被取出"%q.get(True))

        q.task_done() #取出一次数据，将未完成任务-1，不然使用join方法线程会一直阻塞

if __name__=="__main__":

    th1=threading._start_new_thread(sett,()) #不带参数也要传入空元祖不然会报错

    th3=threading._start_new_thread(gett,())

    time.sleep(1) #延时主线程1S，等待put线程已经put部分数据到队列

    q.join()#阻塞主线程，直到未完成任务为0

Python 类中的方法如何多线程调用

# -*- coding: utf-8 -*-import threadingimport threadimport time class Test(object): def __init__(self): # threading.Thread.__init__(self) self._sName = "machao" def process(self): #args是关键字参数，需要加上名字，写成args=(self,) th1 = threading.Thread(target=Test.buildList, args=(self,)) th1.start() th1.join() def buildList(self): while True: print "start" time.sleep(3) test = Test()test.process()