Python threading中lock的使用详解
作者:锅炉房刘大爷 发布时间:2023-01-16 08:32:26
在多线程中使用lock可以让多个线程在共享资源的时候不会“乱”,例如,创建多个线程,每个线程都往空列表l中添加一个数字并打印当前的列表l,如果不加锁,就可能会这样:
# encoding=utf8
import threading
import time
lock = threading.Lock()
l = []
def test1(n):
lock.acquire()
l.append(n)
print l
lock.release()
def test(n):
l.append(n)
print l
def main():
for i in xrange(0, 10):
th = threading.Thread(target=test, args=(i, ))
th.start()
if __name__ == '__main__':
main()
运行结果:
[0]
[0, 1]
[0, 1, 2]
[0, 1, 2, 3][
0, 1, 2, 3, 4]
[0, 1, 2, 3, 4, 5]
[0, 1, 2, 3, 4[, 05, , 16, , 27, ]3
, 4, 5, 6[, 07, , 18, ]2
, 3, 4, [50, , 61, , 72, , 83, , 94],
5, 6, 7, 8, 9]
因为每个线程都在同时往l中添加一个数字(当前每个线程运行的是test函数),然后又可能在同时打印l,所以最后的结果看起来会有些“混乱”。
下面让每个线程调用“test1”函数,看看结果如何:
[0]
[0, 1]
[0, 1, 2]
[0, 1, 2, 3]
[0, 1, 2, 3, 4]
[0, 1, 2, 3, 4, 5]
[0, 1, 2, 3, 4, 5, 6]
[0, 1, 2, 3, 4, 5, 6, 7]
[0, 1, 2, 3, 4, 5, 6, 7, 8]
[0, 1, 2, 3, 4, 5, 6, 7, 8, 9]
现在看起来就好多了,因为test1中每次像l中添加数字并打印之前,都先加了一把“锁”,这样就可以保证每次只有一个线程可以往l中添加数字,而不是同时往l里添加数字。
通过上面的结果比较可以知道,当多线程中需要“独占资源”的时候,要使用锁来控制,防止多个线程同时占用资源而出现其他异常。
使用锁的时候就调用acquire()方法,以此告诉其他线程,我正在占用该资源,你们要等会;待使用资源后需要释放资源的时候就调用release()方法,告诉其他线程,我已经完成使用该资源了,其他人可以过来使用了。
python threading Lock
这篇文章主要是通过代码说明:
threading.Lock()
不影响multiprocessing
.
threading.Lock()
影响threading
.
代码如下:
import threading
import time
from multiprocessing import Pool
_lock = threading.Lock()
def small_func(value):
"""
添加线程锁
:param value:
:return:
"""
print(value)
with _lock:
time.sleep(5)
return value
def no_small_func(value):
"""
没有线程锁
:param value:
:return:
"""
print(value)
# with _lock:
time.sleep(5)
return value
def main():
"""
multiprocessing 是基于进程的,因此线程锁对其不影响,
:return:
"""
st = time.time()
p = Pool(processes=4)
value = p.map(func=small_func, iterable=range(4))
et = time.time()
print(f"all use time: {et - st}")
print(value)
def main2():
"""
threading 受到 线程锁 影响
:return:
"""
st = time.time()
thread_list = []
for temp_value in range(4):
t = threading.Thread(target=small_func, args=(temp_value,))
t.start()
thread_list.append(t)
for i in thread_list:
i.join()
et = time.time()
print(f"all use time: {et - st}")
# print(value)
def main3():
st = time.time()
thread_list = []
res = []
for temp_value in range(4):
# 不加线程锁就行了
t = threading.Thread(target=no_small_func, args=(temp_value,))
t.start()
thread_list.append(t)
for i in thread_list:
v = i.join()
res.append(v)
et = time.time()
print(f"all use time: {et - st}")
print(res)
if __name__ == '__main__':
# main()
# main2()
main3()
来源:https://blog.csdn.net/u012067766/article/details/79733801
猜你喜欢
- 下面这段代码,你知道有哪些错误吗:var g_bar = "bar";function foo(container, c
- 题目:用 JavaScript 代码实现空位补零,比如 pad(12, 3) => 012实现一:/* 平淡无奇法 */functio
- 这里给大家分享一段使用PHP Socket 编程模拟Http post和get请求的代码,非常的实用,结尾部分我们再讨论下php模拟http
- 做为一个专职的页面重构者, 我们从事的工作简单的说就是“将设计稿转换成WEB页面”,这一过程可以很简单到直接把PSD从里导出成网页;也可复杂
- /* JS代码部分 */ 3 const date = new Date()const years = []const months = [
- 第一章:基本的圆角框第二章:透明圆角化背景图片第三章:圆角化图片 第四章:CSS圆角框组件 V1.0序言:在我的文章《超圆滑圆角框的半完美解
- PHP使用星号替代用户名手机和邮箱这个在许多的活动界面会看到如淘宝的购物界面中的一些客户的支付宝号都是隐藏掉的哦,下面我们来看一下它的使用方
- 数据处理在现代企业运营中变得越来越重要,越来越关键,甚至会成为企业发展的一项瓶颈. 数据保护的重要性也不言而喻. 如果一个企业没有很好的数据
- 网页离不开链接,而默认链接的表现形式总是千篇一律的蓝色文字加底线,每当我们点击它时,周围会出现虚线框,表示该链接是当前的焦点,影
- <?php 02 if(!function_exists('get_headers')){ 03&
- 5月20日,微软正式提供了Windows XP下可用的雅黑字体下载,雅黑字体是一款近乎完美的字体,解决了宋体小文字无法辩认的问
- 这里是一个基于GMap2和XML的小例子,数据存在XML文件中 ,这是最简单的模式,却相当地有用。实例的网址是: http://sunjia
- 不知道在坛子里有多少朋友使用触发器,如果你已经对触发器很了解了,那么请跳过此文,如果你还没有使用过触发器的话,那就让我们来认识一下吧。相关阅
- 这篇文章主要介绍了Python argparse模块应用实例解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值
- web2.0的标志是Ajax的异步通信的发掘,给我们带来像google map,google suggest 这样令人惊叹的东西。而Ajax
- 有几个原因促使我们使用自定义的select控件来代替原生的select控件:在ie6下select是一个窗口级的元素,绝对定位的层会被sel
- HTML5之中一个很酷的新特性就是WebSockets,它可以让我们无需AJAX请求即可与服务器端对话。今天彬Go将让大家通过Php环境的服
- location是javascript里边管理地址栏的内置对象,比如location.href就管理页面的url,用location.hre
- COOKIE函数库:cookie.inc.php3 <?php if (!isset($__cookie_inc__)){ $__co
- new fun的执行过程分析,学习面向对象的朋友可以参考下。(1)创建一个新的对象,并让this指针指向它;(2)将函数的prototype