python 线程相关 (七)
2015-09-17 17:10
696 查看
最简单的启动线程
继承threading.Thread,重写run()方法
守护线程
python 线程默认在主线程退出后,子线程还会继续执行
当将线程设为守护线程时,在主线程退出后子线程也会一同结束
线程锁
python 线程虽然是调用系统线程,但由于GIL(全局解释锁),实际使用的还是单核。
python 在线程调度时,是按照执行代码行数进行调度的,一般每执行100行代码(可以通过sys.getcheckinterval()获取),然后开始进行调度,当然调度是随机的。挂起的线程不参与调度(sleep等)
python 多线程适合处理I/O密集型的业务,当处理CPU密集型的业务时最好使用多进程
队列
maxsize:设置队列长度,当该值为空时,默认无限制,当队列长度达到最大值时,线程put方法会被阻塞,直到长度小于最大值
python 线程队列默认是阻塞的,可以使用timeout参数设置等待超时时间
而当block参数为False时,操作队列变为非阻塞方式,并忽略timeout参数,会立即操作队列,如果操作成功,会直接插入/取出数据,否则抛出异常
常用方法:
import threading thread = threading.Thread(target = func, args = (1,2,3)) cmdServer.start()threading.Thread.run() 调用func,threading.Thread.start() 则会调用包含run()的方法。在执行threading.Thread.start()时候,会执行func。
继承threading.Thread,重写run()方法
class Task(threading.Thread) def __init__(): threading.Thread.__init__(self) def run(self): '重写run方法,start启动的时候会调用run方法' pass thread = Task() thread.satrt()
守护线程
python 线程默认在主线程退出后,子线程还会继续执行
当将线程设为守护线程时,在主线程退出后子线程也会一同结束
thread = threading.Thread(target = func, args = (1,2,3)) thread.setDaemon(True) cmdServer.start()
线程锁
lock = threading.Lock() lock.acquire() pass lock.release()
python 线程虽然是调用系统线程,但由于GIL(全局解释锁),实际使用的还是单核。
python 在线程调度时,是按照执行代码行数进行调度的,一般每执行100行代码(可以通过sys.getcheckinterval()获取),然后开始进行调度,当然调度是随机的。挂起的线程不参与调度(sleep等)
python 多线程适合处理I/O密集型的业务,当处理CPU密集型的业务时最好使用多进程
队列
import Queue
maxsize:设置队列长度,当该值为空时,默认无限制,当队列长度达到最大值时,线程put方法会被阻塞,直到长度小于最大值
queue = Queue.Queue(maxsize = 10) queue.put('item') item = queue.get()
python 线程队列默认是阻塞的,可以使用timeout参数设置等待超时时间
queue.put('item', timeout = 10) item = queue.get(timeout = 10)
而当block参数为False时,操作队列变为非阻塞方式,并忽略timeout参数,会立即操作队列,如果操作成功,会直接插入/取出数据,否则抛出异常
queue.put('item', block = False, timeout = 10) item = queue.get(block = False, timeout = 10)
常用方法:
Queue.qsize() 返回队列的大小 Queue.empty() 如果队列为空,返回True,反之False Queue.full() 如果队列满了,返回True,反之False Queue.get() 获取队列,timeout等待时间 Queue.get_nowait() 相当Queue.get(False) Queue.put(item) 写入队列,timeout等待时间 Queue.put_nowait(item) 相当Queue.put(item, False) Queue.task_done() 在完成一项工作之后,Queue.task_done()函数向任务已经完成的队列发送一个信号 Queue.join() 实际上意味着等到队列为空,再执行别的操作
相关文章推荐
- Python动态类型的学习---引用的理解
- Python3写爬虫(四)多线程实现数据爬取
- 垃圾邮件过滤器 python简单实现
- 下载并遍历 names.txt 文件,输出长度最长的回文人名。
- install and upgrade scrapy
- Scrapy的架构介绍
- Centos6 编译安装Python
- 使用Python生成Excel格式的图片
- 让Python文件也可以当bat文件运行
- [Python]推算数独
- Python中zip()函数用法举例
- Python中map()函数浅析
- Python将excel导入到mysql中
- Python在CAM软件Genesis2000中的应用
- 使用Shiboken为C++和Qt库创建Python绑定
- FREEBASIC 编译可被python调用的dll函数示例
- Python 七步捉虫法