[TOC]
## thread模块 较底层次线程模块
使用thread模块开启的线程,会随主线程`一起结束`;为了让子线程能够执行完任务,所以可以让主线程睡眠或者给主线程加锁,等待子线程结束后再释放锁。
```python
#!/usr/bin/env python
#coding: utf-8
#python2
"""为了不让主进程执行完就退出,给主线程加锁,当子线程执行结束后,释放主线程的锁
存在的问题:
当两个线程执行次数不一致时,先结束的线程即会释放主线程的锁,导致未执行完的线程被迫退出
"""
import thread
import time
def processor(thread_name, times):
for i in range(times):
print i, thread_name
time.sleep(0.001)
# for循环结束,释放锁
lock.release()
lock = thread.allocate_lock()
lock.acquire()
thread.start_new_thread(processor, ('image', 5))
thread.start_new_thread(processor, ('sound', 3))
while lock.locked():
pass
```
### 当线程间的执行需要一定次序时,则需要给子线程也加锁。
当主线程,hello线程和world线程,执行到需要获取锁的时候,如果获取不到锁,则阻塞在那里;world线程在获取锁 world_thread_lock的时候阻塞了,当hello线程释放了 锁world_thread_lock,输出了‘world’;此时hello线程也在获取锁过程中阻塞了,所以当world线程释放了hello_thread_lock,输出了hello,这样交替释放彼此的锁,实现了顺序运行
![](http://i2.muimg.com/567571/5ef5968d58a2be35.png)
```python
#!/usr/bin/env python
#coding: utf-8
#python2
import time
import thread
def hello():
for i in xrange(5):
hello_thread_lock.acquire()
print 'hello', time.time(),
world_thread_lock.release()
def world():
for i in xrange(5):
world_thread_lock.acquire()
print 'world', time.time()
hello_thread_lock.release()
time.sleep(1)
# 释放主进程的锁
main_thread_lock.release()
main_thread_lock = thread.allocate_lock()
main_thread_lock.acquire()
hello_thread_lock = thread.allocate_lock()
world_thread_lock = thread.allocate_lock()
world_thread_lock.acquire()
thread.start_new_thread(hello, ())
thread.start_new_thread(world, ())
while main_thread_lock.locked():
pass
```
```python
#!/usr/bin/env python
# coding: utf8
import thread
from time import sleep, ctime
loops = [4, 2]
def loop(nloop, nsec, lock):
print 'start loop', nloop, 'at:', ctime()
sleep(nsec)
print 'loop', nloop, 'done at:', ctime()
lock.release()
def main():
print 'starting threads...'
locks = []
loops_len = range(len(loops))
# 生成锁列表
for i in loops_len:
lock = thread.allocate_lock()
lock.acquire()
locks.append(lock)
# 开启进程
for i in loops_len:
thread.start_new_thread(loop, (i, loops[i], locks[i]))
# 等待所有的lock都释放
for i in loops_len:
while locks[i].locked():
pass
print 'all DONE at:', ctime()
if __name__ == '__main__':
main()
```
- 前言
- 环境搭建
- pypi
- 打包
- Python 2 和 Python 3 的版本之间差别
- 项目
- 第一部分
- 第1章 基础
- Python安装
- python代码文件类型
- python对象
- 核心数据类型
- 核心数据类型--整型和浮点型
- 核心数据类型--字符串
- str.format
- 核心数据类型--列表
- 核心数据类型--元组
- 核心数据类型--字典
- 核心数据类型--集合
- 核心数据类型--文件对象
- 调用bash
- 标准输入输出
- str-repr
- 字符编码
- 迭代器和生成器
- 第2章 语句和语法
- 赋值语句
- if语句
- while语句
- for语句
- assert
- 第3章 函数
- 函数作用域
- 工厂函数
- 内置函数
- 递归
- 嵌套作用域和lambda
- 参数传递
- 函数式编程
- property可写与可读
- 第5章 模块
- 模块导入
- 模块命名空间
- 相对导入和绝对导入
- 模块重载
- 在模块中隐藏数据
- 过渡性重载
- 第6章 类
- 面向对象还是面向过程?
- 构造函数 析构函数
- call
- 运算符重载
- str()
- 待定
- 即时生成属性
- 多态
- 线程和进程
- thread模块
- threading模块
- threading线程锁
- 糖果机
- multiprocessing
- 阻塞非阻塞同步异步
- 单线程和多线程对比
- 生产者消费者模型
- 第二部分
- 获取系统资源信息
- 获取进程所占的物理内存
- dmidecode获取系统信息
- 网络编程
- 网络基础
- python中的套接字
- socket模块
- 第三部分 高级功能
- 闭包入门
- 闭包的应用
- 装饰器入门
- 装饰器应用
- 第四部分 项目实战
- graphite
- 模块
- collections
- datetime
- Enum
- faker
- fabric
- fileinput
- fire
- fnmatch
- getpass
- glob
- hashlib
- heapq
- json模块
- log
- os
- Paramiko
- parser
- platform
- pyyaml
- Queue
- random
- re
- 特殊符号和字符
- re模块
- shelves
- subprocess
- time
- urllib_urllib2_requests
- urllib urllib2
- requests
- 标准模块ConfigParser
- 扩展模块Mysqldb
- 扩展模块dns
- 扩展模块request
- uuid
- cacheout 缓存库
- delorean 时间
- 附录
- 内置函数
- python实现各种排序算法
- 常见报错
- pymongo
- pyrocksdb
- 常用
- ERROR