Python中多线程thread与threading的实现方法,pythonthreading
Python中多线程thread与threading的实现方法,pythonthreading
学过Python的人应该都知道,Python是支持多线程的,并且是native的线程。本文主要是通过thread和threading这两个模块来实现多线程的。
python的thread模块是比较底层的模块,python的threading模块是对thread做了一些包装的,可以更加方便的被使用。
这里需要提一下的是python对线程的支持还不够完善,不能利用多CPU,但是下个版本的python中已经考虑改进这点,让我们拭目以待吧。
threading模块里面主要是对一些线程的操作对象化了,创建了叫Thread的class。
一般来说,使用线程有两种模式,一种是创建线程要执行的函数,把这个函数传递进Thread对象里,让它来执行;另一种是直接从Thread继承,创建一个新的class,把线程执行的代码放到这个新的 class里。
我们来看看这两种做法吧。
一、Python thread实现多线程
#-*- encoding: gb2312 -*- import string, threading, time def thread_main(a): global count, mutex # 获得线程名 threadname = threading.currentThread().getName() for x in xrange(0, int(a)): # 取得锁 mutex.acquire() count = count + 1 # 释放锁 mutex.release() print threadname, x, count time.sleep(1) def main(num): global count, mutex threads = [] count = 1 # 创建一个锁 mutex = threading.Lock() # 先创建线程对象 for x in xrange(0, num): threads.append(threading.Thread(target=thread_main, args=(10,))) # 启动所有线程 for t in threads: t.start() # 主线程中等待所有子线程退出 for t in threads: t.join() if __name__ == '__main__': num = 4 # 创建4个线程 main(4)
二、Python threading实现多线程
#-*- encoding: gb2312 -*- import threading import time class Test(threading.Thread): def __init__(self, num): threading.Thread.__init__(self) self._run_num = num def run(self): global count, mutex threadname = threading.currentThread().getName() for x in xrange(0, int(self._run_num)): mutex.acquire() count = count + 1 mutex.release() print threadname, x, count time.sleep(1) if __name__ == '__main__': global count, mutex threads = [] num = 4 count = 1 # 创建锁 mutex = threading.Lock() # 创建线程对象 for x in xrange(0, num): threads.append(Test(10)) # 启动线程 for t in threads: t.start() # 等待子线程结束 for t in threads: t.join()
相信本文所述Python多线程实例对大家的Python程序设计能够起到一定的借鉴价值。
多线程/多进程都是通讯或者回调,而不是直接返回结果。这个很容易理解的,因为如果你用返回结果来给一个变量赋值,你就必须等待这个函数结束,你这个程序就阻塞了,这就失去了多线程/多进程防止阻塞的意义了。
通讯可以是事件驱动或者用线程安全的数据结构来传递数据(比如Queue,也可以是消息队列0mq,rabbitMQ之类),回调就是你一个程序执行完成后调用另外一个函数来处理接下来怎么做。
这个不用你去写。在python里现成的。只要重载ThreadingServer和SocketServer就可以了。你自己去看python帮助里的例子代码,也可以去site-packages里去看源码。
大概的是这样
soc=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
soc.bind(....)
while True:
client=soc.listen(1)
start_thread(function_thread, (client,))
def function_thread(client):
buf=client.recv()
....
相关内容
- Python中列表(list)操作方法汇总,pythonlist
- python调用Moxa PCOMM Lite通过串口Ymodem协议实现发送文件,
- Python异常处理总结,python异常处理
- 基于Python的身份证号码自动生成程序,python身份证号码
- 一个计算身份证号码校验位的Python小程序,python小程序
- Python常用正则表达式符号浅析,python正则表达式
- Python3基础之基本数据类型概述,python3数据类型
- Python正则表达式的使用范例详解,python正则表达式
- Python入门及进阶笔记 Python 内置函数小结,python进阶
- Python-基础-入门 简介,python-入门
评论关闭