python 中的多线程同步

Question

我遇到一个问题，我需要 x 个线程等待它们全部到达同步点。 我的解决方案使用下面的 synchronise 方法，每个线程函数在需要同步时都会调用该方法。

有一个更好的方法吗？

thread_count = 0
semaphore = threading.Semaphore()
event = threading.Event()

def synchronise(count):
    """ All calls to this method will block until the last (count) call is made """
    with semaphore:
        thread_count += 1
        if thread_count == count:
            event.set()

    event.wait()

def threaded_function():
    # Do something

    # Block until 4 threads have reached this point
    synchronise(4)

    # Continue doing something else

Answer 1

请注意，Barrier 已从 Python 3.2 起实现

使用屏障的示例：

from threading import Barrier, Thread

def get_votes(site):
    ballots = conduct_election(site)
    all_polls_closed.wait()        # do not count until all polls are closed
    totals = summarize(ballots)
    publish(site, totals)

all_polls_closed = Barrier(len(sites))
for site in sites:
    Thread(target=get_votes, args=(site,)).start()

Answer 2

同步线程的方法有很多种。 许多。

除了同步之外，您还可以执行以下操作。

1. 围绕同步点将您的任务分成两个步骤。 启动线程执行预同步步骤。 然后使用“join”等待所有线程完成步骤 1。启动新线程执行同步后步骤。 与同步相比，我更喜欢这个。

2. 创建队列； 获取同步锁。 启动所有线程。 每个线程都会在队列中放入一个条目并等待同步锁。 “主”线程位于循环中，使项目从队列中出列。 当所有线程都将一个项目放入队列时，“主”线程释放同步锁。 所有其他线程现在可以再次自由运行。

有多种进程间通信（IPC）技术——所有这些技术都可以用于线程同步。

Answer 3

您想要的功能称为“屏障”。 （不幸的是，在谈论线程时，该术语有两种含义。因此，如果您 Google 即可，忽略谈论“内存屏障" - 这是一个非常不同的事情）。

你的代码看起来很合理——简单又安全。

我找不到任何 Python 屏障的“标准”实现，因此我建议您继续使用您的代码。