Каналы CSP с собственной потоковой обработкой в ​​Python

Question

Я ищу реализацию каналов CSP поверх собственных потоков в Python. Я видел несколько библиотек, но они включают все, кроме кухонной раковины.

В частности, я ищу возможность дождаться первого из множества операций отправки и получения по нескольким каналам и либо вернуть результаты первой завершенной операции, либо вызвать обратный вызов.

Вот несколько связанных ссылок для контекста:

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

Answer 1

Да, моя библиотека питон-СНТ имеет все это. Вы можете получить библиотеку здесь: 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 
>>> 

Я в середине рефакторинга внутренностей и очистку вещи вверх , так что следите за выпуском в ближайшее время или не стесняйтесь отправлять мне по электронной почте офлайн, если хотите.