В Python без стека вы можете отправить канал по каналу? - PullRequest
Новая
       13

В Python без стека вы можете отправить канал по каналу?

4 голосов
/ 12 марта 2009

У меня нет без стека в данный момент, поэтому я не могу попробовать это сам. 

import stackless
ch1 = stackless.channel()
ch2 = stackless.channel()

ch1.send(ch2)
ch3 = ch1.receive()

Являются ли ch2 и ch3 одним и тем же каналом? Скажи: 

text = "Hallo"
ch2.send(text)
assert text == ch3.receive()

Эта функция напомнила мне о разговоре о Newsqueak , который Роберт Пайк (из Plan9 слава) дал в Google. В Newsqueak вы можете отправлять каналы по каналам.

Ответы [ 2 ]

4 голосов
/ 12 марта 2009

Да. Только что протестировано. 

>>> import stackless
>>> ch1 = stackless.channel()
>>> def a():
...  ch2 = stackless.channel()
...  ch1.send(ch2)
...  ch2.send("Hello")
...
>>> def b():
...  ch3 = ch1.receive()
...  print ch3.receive()
...
>>> stackless.tasklet(a)()
<stackless.tasklet object at 0x01C6FCB0>
>>> stackless.tasklet(b)()
<stackless.tasklet object at 0x01C6FAB0>
>>> stackless.run()
Hello
3 голосов
/ 12 марта 2009

Каналы отправляют обычные ссылки на Python, поэтому отправляемые вами данные (канал, строка и т. Д.) В точности совпадают с полученными.

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

Вот экстремальный пример, который я разработал для моей Stackless talk на PyCon несколько лет назад. Это создает новый тасклет для каждого вызова функции, так что я могу использовать рекурсивную реализацию факториала, которому не нужно беспокоиться об ограничении стека Python. Я выделяю тасклет для каждого вызова, и он получает обратный канал для результата. 

import stackless 

def call_wrapper(f, args, kwargs, result_ch): 
    result_ch.send(f(*args, **kwargs)) 
    # ... should also catch and forward exceptions ... 

def call(f, *args, **kwargs): 
    result_ch = stackless.channel() 
    stackless.tasklet(call_wrapper)(f, args, kwargs, result_ch) 
    return result_ch.receive() 

def factorial(n): 
    if n <= 1: 
        return 1 
    return n * call(factorial, n-1) 

print "5! =", factorial(5) 
print "1000! / 998! =", factorial(1000)/factorial(998)

Вывод: 

5! = 120 
1000! / 998! = 999000

У меня есть несколько других примеров отправки каналов по каналам в моей презентации. В Stackless это обычное дело.

...