Implementing Barrier in Python2.7(Python2.7中实现Barrier)
本文介绍了Python2.7中实现Barrier的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
I have this code implemented in Python3 using Barriers. I want to get the same functionality in Python2.7 but i don't know which synchronization primitive to use as Barriers are not there in Python2.7
import threading
import time
from threading import Thread,Barrier
b = Barrier(2, timeout=50)
def func1():
time.sleep(3)
b.wait()
print('Working from func1')
return
def func2():
time.sleep(5)
b.wait()
print('Working from func2')
return
if __name__ == '__main__':
Thread(target = func1).start()
Thread(target = func2).start()
解决方案
You can simulate the barrier with semaphores. Take a look at: Implementing an N process barrier using semaphores
The problem is that it has no timeout parameter, maybe using Conditions ...
import time
from threading import Thread,Semaphore
class Barrier:
def __init__(self, n):
self.n = n
self.count = 0
self.mutex = Semaphore(1)
self.barrier = Semaphore(0)
def wait(self):
self.mutex.acquire()
self.count = self.count + 1
self.mutex.release()
if self.count == self.n: self.barrier.release()
self.barrier.acquire()
self.barrier.release()
b = Barrier(2)
def func1():
time.sleep(3)
#
b.wait()
#
print('Working from func1')
return
def func2():
time.sleep(5)
#
b.wait()
#
print('Working from func2')
return
if __name__ == '__main__':
Thread(target = func1).start()
Thread(target = func2).start()
这篇关于Python2.7中实现Barrier的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!
沃梦达教程
本文标题为:Python2.7中实现Barrier


基础教程推荐
猜你喜欢
- 求两个直方图的卷积 2022-01-01
- 包装空间模型 2022-01-01
- Plotly:如何设置绘图图形的样式,使其不显示缺失日期的间隙? 2022-01-01
- 在同一图形上绘制Bokeh的烛台和音量条 2022-01-01
- 在Python中从Azure BLOB存储中读取文件 2022-01-01
- 无法导入 Pytorch [WinError 126] 找不到指定的模块 2022-01-01
- 修改列表中的数据帧不起作用 2022-01-01
- PANDA VALUE_COUNTS包含GROUP BY之前的所有值 2022-01-01
- PermissionError: pip 从 8.1.1 升级到 8.1.2 2022-01-01
- 使用大型矩阵时禁止 Pycharm 输出中的自动换行符 2022-01-01