Python threading多线程编程实例-CDA数据分析师官网

Python threading多线程编程实例

2018-02-02

Python threading多线程编程实例

这篇文章主要介绍了Python threading多线程编程实例,本文讲解了使用函数和线程类实现多线程编程的例子,需要的朋友可以参考下

Python 的多线程有两种实现方法：

函数，线程类

1.函数

调用 thread 模块中的 start_new_thread() 函数来创建线程，以线程函数的形式告诉线程该做什么

代码如下:
# -*- coding: utf-8 -*-
import thread
def f(name):
#定义线程函数
print "this is " + name

if __name__ == '__main__':
thread.start_new_thread(f, ("thread1",))
#用start_new_thread()调用线程函数和其他参数
while 1:
pass

不过这种方法暂时没能找到其他辅助方法，连主线程等待都要用 while 1 这种方法解决。

2.线程类

调用 threading 模块，创建 threading.Thread 的子类来得到自定义线程类。

代码如下:
# -*- coding: utf-8 -*-
import threading
class Th(threading.Thread):
def __init__(self, name):
    threading.Thread.__init__(self)
    self.t_name = name
    #调用父类构造函数

def run(self):
    #重写run()函数，线程默认从此函数开始执行
    print "This is " + self.t_name

if __name__ == '__main__':
thread1 = Th("Thread_1")
thread1.start()
#start()函数启动线程，自动执行run()函数

threading.Thread 类的可继承函数：
getName() 获得线程对象名称
setName() 设置线程对象名称
join() 等待调用的线程结束后再运行之后的命令
setDaemon(bool) 阻塞模式， True：父线程不等待子线程结束， False 等待，默认为 False
isDaemon() 判断子线程是否和父线程一起结束，即 setDaemon() 设置的值
isAlive() 判断线程是否在运行

实例

join() 阻塞等待

代码如下:
if __name__ == '__main__':
    thread1 = Th("T1 ")
    thread1.start()
    #thread1.join()
    print "main thread is over"

不带 thread1.join() ，得到如下结果：

代码如下:
This is thread T1
main thread is over
0
1
2
T1 is over

不等待 thread1 完成，执行之后语句。
加了 thread1.join() ，得到如下结果：

代码如下:
This is thread T1
0
1
2
T1 is over
main thread is over

阻塞等待 thread1 结束，才执行下面语句

主线程等待

代码如下:
if __name__ == '__main__':
thread1 = Th("T1 ")
thread1.setDaemon(True)
#要在线程执行之前就设置这个量
thread1.start()
print "main thread is over"

报错： Exception in thread T1 (most likely raised during interpreter shutdown):
也就是主线程不等待子线程就结束了。

多个子线程

代码如下:
if __name__ == '__main__':
    for i in range(3):
        t = Th(str(i))
        t.start()
    print "main thread is over"

这里的 t 可同时处理多个线程，即 t 为线程句柄，重新赋值不影响线程。

这里奇怪的是，运行 t.run() 时，不会再执行其他线程。虽不明，还是用 start() 吧。暂且理解为 start() 是非阻塞并行的，而 run 是阻塞的。

线程锁

threading 提供线程锁，可以实现线程同步。

代码如下:
import threading
import time
class Th(threading.Thread):
def __init__(self, thread_name):
    threading.Thread.__init__(self)
    self.setName(thread_name)

def run(self):
    threadLock.acquire()
    #获得锁之后再运行
    print "This is thread " + self.getName()
    for i in range(3):
      time.sleep(1)
      print str(i)
    print self.getName() + " is over"
    threadLock.release()
    #释放锁
if __name__ == '__main__':
threadLock = threading.Lock()
#设置全局锁
thread1 = Th('Thread_1')
thread2 = Th('Thread_2')
thread1.start()
thread2.start()

得到结果：

代码如下:

This is thread Thread_1
0
1
2
Thread_1 is over
This is thread Thread_2
0
1
2
Thread_2 is over

CDA数据分析师考试相关入口一览（建议收藏）：

▷ 想报名CDA认证考试，点击>>> “CDA报名” 了解CDA考试详情；

▷ 想加入CDA考试题库，点击>>> “CDA题库” 了解CDA考试详情；

▷ 想学习CDA考试教材，点击>>> “CDA教材” 了解CDA考试详情；

▷ 想查询CDA考试成绩，点击>>> “CDA成绩” 了解CDA考试详情；

▷ 想了解CDA考试含金量，点击>>> “CDA含金量” 了解CDA考试详情；

▷ 想获取CDA考试时间/费用/条件/大纲/通过率，点击 >>>“CDA考试官网” 了解CDA考试详情；

数据分析咨询请扫描二维码

上一篇回归系列（一）| 怎样正确地理解线性回归

下一篇2020美国总统竞选大戏开锣，川普当选的奇迹会再发生吗？

Python threading多线程编程实例

CDA考试动态

CDA报考指南

热门栏目

最新资讯

数据分析师教程《Python数据分析极简入门》第2节 5 ...

数据分析需要学哪些方面

数据分析适合在什么单位工作

数据分析是什么工作内容

数据分析师需要掌握什么技能

数据开发和数据分析区别

数据架构师是干什么的

数据分析师需要具备的能力

数据分析师需要具备的技能有哪些

数据分析师需要具备的技能和能力

数据分析师的发展前景

数据分析师教程《Python数据分析极简入门》第2节 4 ...

数据分析师的工作内容是什么

数据分析师必须掌握的技能有哪些

数据分析入门难吗

数据分析能干啥

数据分析行业的前景

数据分析的常用方法

什么是企业数字化转型

女生做数据分析师最好去哪个行业