Python2.7中实现Barrier

织梦狗教程 Python问题

2022-01-01

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的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持编程学习网！

Python