python多线程的几种方法

python多线程的几种方法python多线程编程Python多线程编程中常用方法:1、join()方法:如果一个线程或者在函数执行的过程中调用另一个线程,并且希望待其完成操作后才能执行,那么在调用线程的时就可以使用被调线程

大家好,又见面了,我是你们的朋友全栈君。

python多线程编程

 

Python多线程编程中常用方法:

1、join()方法:如果一个线程或者在函数执行的过程中调用另一个线程,并且希望待其完成操作后才能执行,那么在调用线程的时就可以使用被调线程的join方法join([timeout]) timeout:可选参数,线程运行的最长时间

2、isAlive()方法:查看线程是否还在运行

3、getName()方法:获得线程名

4、setDaemon()方法:主线程退出时,需要子线程随主线程退出,则设置子线程的setDaemon()

Python线程同步:

(1)Thread的Lock和RLock实现简单的线程同步:

复制代码
import threading import time class mythread(threading.Thread): def __init__(self,threadname): threading.Thread.__init__(self,name=threadname) def run(self): global x lock.acquire() for i in range(3): x = x+1 time.sleep(1) print x lock.release() if __name__ == '__main__': lock = threading.RLock() t1 = [] for i in range(10): t = mythread(str(i)) t1.append(t) x = 0 for i in t1: i.start()
复制代码

(2)使用条件变量保持线程同步:

复制代码
# coding=utf-8 import threading class Producer(threading.Thread): def __init__(self,threadname): threading.Thread.__init__(self,name=threadname) def run(self): global x con.acquire() if x == 10000: con.wait() pass else: for i in range(10000): x = x+1 con.notify() print x con.release() class Consumer(threading.Thread): def __init__(self,threadname): threading.Thread.__init__(self,name=threadname) def run(self): global x con.acquire() if x == 0: con.wait() pass else: for i in range(10000): x = x-1 con.notify() print x con.release() if __name__ == '__main__': con = threading.Condition() x = 0 p = Producer('Producer') c = Consumer('Consumer') p.start() c.start() p.join() c.join() print x
复制代码

(3)使用队列保持线程同步:

复制代码
# coding=utf-8 import threading import Queue import time import random class Producer(threading.Thread): def __init__(self,threadname): threading.Thread.__init__(self,name=threadname) def run(self): global queue i = random.randint(1,5) queue.put(i) print self.getName(),' put %d to queue' %(i) time.sleep(1) class Consumer(threading.Thread): def __init__(self,threadname): threading.Thread.__init__(self,name=threadname) def run(self): global queue item = queue.get() print self.getName(),' get %d from queue' %(item) time.sleep(1) if __name__ == '__main__': queue = Queue.Queue() plist = [] clist = [] for i in range(3): p = Producer('Producer'+str(i)) plist.append(p) for j in range(3): c = Consumer('Consumer'+str(j)) clist.append(c) for pt in plist: pt.start() pt.join() for ct in clist: ct.start() ct.join()
复制代码

生产者消费者模式的另一种实现:

复制代码
# coding=utf-8 import time import threading import Queue class Consumer(threading.Thread): def __init__(self, queue): threading.Thread.__init__(self) self._queue = queue def run(self): while True: # queue.get() blocks the current thread until an item is retrieved. msg = self._queue.get() # Checks if the current message is the "quit" if isinstance(msg, str) and msg == 'quit': # if so, exists the loop break # "Processes" (or in our case, prints) the queue item print "I'm a thread, and I received %s!!" % msg # Always be friendly! print 'Bye byes!' class Producer(threading.Thread): def __init__(self, queue): threading.Thread.__init__(self) self._queue = queue def run(self): # variable to keep track of when we started start_time = time.time() # While under 5 seconds.. while time.time() - start_time < 5: # "Produce" a piece of work and stick it in the queue for the Consumer to process self._queue.put('something at %s' % time.time()) # Sleep a bit just to avoid an absurd number of messages time.sleep(1) # This the "quit" message of killing a thread. self._queue.put('quit') if __name__ == '__main__': queue = Queue.Queue() consumer = Consumer(queue) consumer.start() producer1 = Producer(queue) producer1.start()
复制代码

使用线程池(Thread pool)+同步队列(Queue)的实现方式:

复制代码
# A more realistic thread pool example # coding=utf-8 import time import threading import Queue import urllib2 class Consumer(threading.Thread): def __init__(self, queue): threading.Thread.__init__(self) self._queue = queue def run(self): while True: content = self._queue.get() if isinstance(content, str) and content == 'quit': break response = urllib2.urlopen(content) print 'Bye byes!' def Producer(): urls = [ 'http://www.python.org', 'http://www.yahoo.com' 'http://www.scala.org', 'http://cn.bing.com' # etc..  ] queue = Queue.Queue() worker_threads = build_worker_pool(queue, 4) start_time = time.time() # Add the urls to process for url in urls: queue.put(url) # Add the 'quit' message for worker in worker_threads: queue.put('quit') for worker in worker_threads: worker.join() print 'Done! Time taken: {}'.format(time.time() - start_time) def build_worker_pool(queue, size): workers = [] for _ in range(size): worker = Consumer(queue) worker.start() workers.append(worker) return workers if __name__ == '__main__': Producer()
复制代码

另一个使用线程池+Map的实现:

复制代码
import urllib2 from multiprocessing.dummy import Pool as ThreadPool urls = [ 'http://www.python.org', 'http://www.python.org/about/', 'http://www.python.org/doc/', 'http://www.python.org/download/', 'http://www.python.org/community/' ] # Make the Pool of workers pool = ThreadPool(4) # Open the urls in their own threads # and return the results results = pool.map(urllib2.urlopen, urls) #close the pool and wait for the work to finish pool.close() pool.join()
复制代码

 

参考: http://blog.jobbole.com/58700

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/155878.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 提高效率:公司内外网同时使用

    提高效率:公司内外网同时使用

  • 用 managedQuery() 时须要注意的一个陷阱

    用 managedQuery() 时须要注意的一个陷阱

  • 评日报文章:关于华为裁员

    评日报文章:关于华为裁员今天看了一篇日报:CSDN日报20170304——《令人比较失落的IT圈子-关于华为裁员》看了前半部分,就没有往下看了。讲的有所道理,但是总觉得文字中似乎有种怨念,不够通透,明亮。就说一个我比较关心的观点吧:IT门槛低,不如物理,化学,生物制药这类学科。部分承认,但是综合考虑社会发展状况,这是很容易看明白的一个现象,文章前半部分都已经说了,和国家大力扩招,培养发展计算机产业是有很大关系的。社会发展到

  • VSCode汉化_vscode汉化插件

    VSCode汉化_vscode汉化插件1.打开VSCode点击箭头指示地方在搜索框中输入chinese然后安装中文简体2.按住Ctrl+shift+p选择配置显示语言然后会看见下面的样子添加"locale&qu

  • GSLB负载均衡策略

    GSLB负载均衡策略负载均衡策略1.静态策略1)基于特定的用户源IP地址:特定的IP地址段定向到特定的POP节点或者虚拟服务器2)基于加权的IP地址:这里的IP地址是服务池中的虚拟服务器的IP地址.他们的权重不同,这样GSLB在为用户请求轮询解析域名时,根据权重来选择IP3)基于加权的POP节点:基于物理上的节点4)基于地理位置:选择一个在地理位置上与用户距离最近的POP节点或者虚拟服…

  • 笔记———No.1 使用matlab画圆「建议收藏」

    笔记———No.1 使用matlab画圆「建议收藏」//Anhighlightedblockfunctionra(r,X,Y)%r=5;%半径%X=6;%圆心x坐标%Y=-5;%圆心y坐标b=0.001;%精确值x=(X-r):b:(X+r);%x的范围y=sqrt(r

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号