python 多线程简单实现
1. 线程是什么?
线程,有时被称为轻量级进程(Lightweight Process,LWP),是程序执行流的最小单元。
2 为什么要用线程?
a 单个线程可以在进程中独立运行
c 并行操作,适用于C/S架构
3 python怎么生成线程(将函数生成线程):
# -*- coding: UTF-8 -*-
import threading #加载线程模块
import time
#演示用函数run
def run(num):
print "Hi,I am thread %s.....lalala" %num
time.sleep(3)
for i in range(30):
t = threading.Thread(target=run,args=(i,))
#使用threading模块Thread方法生成一个线程
#target=你要运行的函数,args=你运行的函数的参数,后面的","是不能省略的
t.start()
#调用start方法,执行run()方法,也就是定义的函数
总结:
生成线程就2个步骤:
1.加载threading模块
2.使用threading.Thread方法实例化一个对象就行
4 python怎么生成线程(将类生成线程):
# -*- coding: UTF-8 -*-
import threading
import time
#将自定义的类,继承threading.Thread方法
class MyThread(threading.Thread):
#构建初始化类的方法
def __init__(self,num):
#继承threading.Thread的初始化类的方法
threading.Thread.__init__(self)
self.num = num
#此处定义的方法名,必须是run方法
def run(self):
print "Hi,I am thread %s.....lalala" %self.num
time.sleep(3)
for i in range(30):
t = MyThread(i)
#继承threading.Thread方法后,实例化自定义类后,会自动执行run方法
t.start()
总结:
通过自定义类,继承threading.Thread类,要通过一定的规则来生成线程:
1.自定义类继承threading.Thread类
2.继承threading.Thread的__init__初始化类的方法
3.构建run方法
4.实例化自定义类,就会将自定义类中run方法给自动执行成一个线程
5 线程锁
如果线程执行的函数内有变量共用一个全局变量,那么并发线程在执行中,会导致这个变量数值出现变化,从而导致结果错误(而线程需要执行的函数内的变量,定义为全局变量本省就不正常)
#!/usr/bin/env python
import threading
import time
number = 0
lock = threading.RLock()
#实例化线程锁Rlock类
def run(num):
lock.acquire()
#调用acquire方法为线程加所
#number = 0
print "Hi,I am thread %s.....lalala" %num
global number
number +=1
print "this is thread " ,num,number
lock.release()
#调用release方法为线程解锁
time.sleep(3)
for i in range(30):
t = threading.Thread(target=run,args=(i,))
t.start()
补充:
threading.Thread类的使用:
1,在自己的线程类的__init__里调用threading.Thread.__init__(self, name = threadname)
Threadname为线程的名字
2, run(),通常需要重写,编写代码实现做需要的功能。
3,getName(),获得线程对象名称
4,setName(),设置线程对象名称
5,start(),启动线程
6,join([timeout]),等待另一线程结束后再运行。
在循环内,join()的作用是,在子线程完成运行之前,这个子线程的父线程将一直被阻塞。
注意: join()方法的位置是在for循环外的,也就是说必须等待for循环里的两个进程都结束后,才去执行主进程。
7,setDaemon(bool),设置子线程是否随主线程一起结束,必须在start()之前调用。默认为False。
8,isDaemon(),判断线程是否随主线程一起结束。
9,isAlive(),检查线程是否在运行中。
相关文章