[解析]多线程加锁Lock调用python2

没有加锁的代码如下

from atexit import register
from random import randrange
from threading import Thread, currentThread
from time import sleep, ctimeclass CleanOutputSet(set):def __str__(self):return ', '.join(x for x in self)loops = (randrange(2, 5) for x in xrange(randrange(3, 7)))
remaining = CleanOutputSet()def loop(nsec):myname = currentThread().nameremaining.add(myname)print '[%s] Start %s' % (ctime(), myname)sleep(nsec)remaining.remove(myname)print '[%s] Completed %s (%d sec)' % (ctime(), myname, nsec)print '     remaining: %s' % (remaining or 'NONE')def main():for pause in loops:Thread(target=loop, args=(pause,)).start()@register
def _atexit():print 'End'if __name__ == '__main__':main()

没有加锁的情况下输出（中间或者后面的那些空行也是输出的部分）

[Fri Mar 09 21:17:53 2018] Start Thread-1
[Fri Mar 09 21:17:53 2018] Start Thread-2
[Fri Mar 09 21:17:53 2018] Start Thread-3
[Fri Mar 09 21:17:53 2018] Start Thread-4
[Fri Mar 09 21:17:53 2018] Start Thread-5
[Fri Mar 09 21:17:55 2018] Completed Thread-4 (2 sec)remaining: Thread-5, Thread-3, Thread-2, Thread-1
[Fri Mar 09 21:17:55 2018] Completed Thread-5 (2 sec)remaining: Thread-3, Thread-2, Thread-1
[Fri Mar 09 21:17:57 2018] Completed Thread-3 (4 sec)[Fri Mar 09 21:17:57 2018] Completed Thread-1 (4 sec)[Fri Mar 09 21:17:57 2018] Completed Thread-2 (4 sec)remaining: NONE     remaining: NONE     remaining: NONE

由于没有加锁导致在输出的过程中，会使得整个IO变的很乱，还有，处理在全局变量中的remaining 那个set继承下来的东西时，会变的很麻烦。

总之，我们需要学习加锁的机制，只有这样才能更好地使用并发的机制。

加锁的代码

关键代码：

from threading import Thread, currentThread, Lock
lock = Lock()  # 放到全局变量当中

修改一下对应的loop部分，其他地方不变

def loop(nsec):myname = currentThread().namelock.acquire()remaining.add(myname)print '[%s] Start %s' % (ctime(), myname)lock.release()sleep(nsec)lock.acquire()remaining.remove(myname)print '[%s] Completed %s (%d sec)' % (ctime(), myname, nsec)print '     remaining: %s' % (remaining or 'NONE')lock.release()

或者是改成这样也是可以的

def loop(nsec):myname = currentThread().namewith lock:remaining.add(myname)print '[%s] Start %s' % (ctime(), myname)sleep(nsec)with lock:remaining.remove(myname)print '[%s] Completed %s (%d sec)' % (ctime(), myname, nsec)print '     remaining: %s' % (remaining or 'NONE')

[解析]多线程加锁Lock调用python2相关推荐

c# 多线程中lock用法的经典实例
一.Lock定义 lock 关键字可以用来确保代码块完成运行,而不会被其他线程中断.它可以把一段代码定义为互斥段(critical section),互斥段在一个时刻内只允许一个线程进入执行, ...
C#多线程中lock的用法
最近在看些c#的代码,发现很多是以前没有接触到了,只能上网查,把比较好的整理下来. 经常碰到同时需要对某个数据进行操作,或者对某个文件进行读写操作,对于这些操作我们以前往往不能很好的进行处理,自从C# ...
Java 多线程加锁的方式总结及对比
前言 Java多线程可以通过: synchronized关键字 Java.util.concurrent包中的lock接口和ReentrantLock实现类这两种方式实现加锁. Lock 和 syn ...
Java多线程(五) Lock接口,ReentranctLock,ReentrantReadWriteLock
在JDK5里面,提供了一个Lock接口.该接口通过底层框架的形式为设计更面向对象.可更加细粒度控制线程代码.更灵活控制线程通信提供了基础.实现Lock接口且使用得比较多的是可重入锁(Reentrant ...
python多线程加锁异步处理装饰器
2019独角兽企业重金招聘Python工程师标准>>> 前言: 虽谈python多线程带有全局锁PIL,似乎对性能提升没什么意义,一般考虑多进程或者协程,但PIL没有被去掉还是应该有 ...
Java 多线程启动为什么调用 start() 方法而不是 run() 方法？
点击上方好好学java ,选择星标公众号重磅资讯.干货,第一时间送达今日推荐:终于放弃了单调的swagger-ui了,选择了这款神器-knife4j个人原创100W+访问量博客:点击前往,查 ...
python类库32[多线程同步Lock+RLock+Semaphore+Event]
2019独角兽企业重金招聘Python工程师标准>>> 一多线程同步由于CPython的python解释器在单线程模式下执行,所以导致python的多线程在很多的时候并不能很好地 ...
ThreadLocal原理解析以及是否需要调用remove方法
平常的开发过程中,如果有个类不是线程安全的,比如SimpleDateFormat,要使这个类在并发的过程中是线程安全的,那么可以将变量设置位局部变量,不过存在的问题就是频繁的创建对象,对性能和资源会有 ...
python线程安全的计数器_Python多线程同步Lock、RLock、Semaphore、Event实例
一.多线程同步由于CPython的python解释器在单线程模式下执行,所以导致python的多线程在很多的时候并不能很好地发挥多核cpu的资源.大部分情况都推荐使用多进程. python的多线程的 ...

[解析]多线程加锁Lock调用python2

没有加锁的代码如下

没有加锁的情况下输出（中间或者后面的那些空行也是输出的部分）

加锁的代码

修改一下对应的loop部分，其他地方不变

或者是改成这样也是可以的

[解析]多线程加锁Lock调用python2相关推荐

最新文章

热门文章