在Python中使用本机线程的CSP通道

Question

我在寻找在Python中本机线程之上的CSP通道的实现。我看过一些图书馆，但里面除了厨房的水槽，什么都有。在

具体地说，我希望能够在多个通道上等待一组发送和接收操作中的第一个操作，并将第一个完成的操作的结果返回给我，或者调用回调。在

以下是一些与上下文相关的链接：

• Communicating sequential processes
• Multiplex on queue.Queue?
• Go specification: Select statements

Answer 1

是的，我的库python csp有所有这些。你可以在这里得到图书馆：https://github.com/futurecore/python-csp

下面是一个关于频道和高度的简单示例（也称为非确定性选择）：

>>> @process
... def send_msg(chan, msg):
...     chan.write(msg)
... 
>>> @process
... def alt_example(chan1, chan2):
...     alt = Alt(chan1, chan2)
...     print alt.select()
...     print alt.select()
... 
>>> c1, c2 = Channel(), Channel()
>>> Par(send_msg(c1, 'yes'), send_msg(c2, 'no'), alt_example(c1, c2)).start()
yes
no
>>>

我正在重构内部结构和清理东西，所以请留意一下很快发布的版本，如果你愿意的话，可以发邮件给我。在