在Python2.7中实现屏障

Question

我使用Barriers在Python3中实现了此代码。我想在Python2.7相同的功能，但我不知道用哪个同步原语的障碍是不是有在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() 

Answer 1

您可以模拟信号量的屏障。 看看： Implementing an N process barrier using semaphores

的问题是，它没有超时参数，也许使用条件......

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()