求助：兩個無限循環(huán)線程切換的問題～

zengleo

我用的是stackless模塊

我有兩個無限循環(huán)

一個線程是無限循環(huán)檢測一個值的變化
另外一個是接受udp包

設(shè)置兩個通道
one=stackless.channel()
two=stackless.channel()

def  check():
     two.recevie()
     while 1:
           if 檢測值 a=1：
               dosomething
           else:
              one.send('開始收包')


def udp():
   
    one.receive()
    s=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
    s.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
    s.bind((loaclhost_ip,port))
    while 1:
        d,a=s.recvfrom(1024)
         two.send('返回check')


開啟線程

stackless.tasklet(check)()
stackless.tasklet(udp)()
stackless.tasklet(two.send)('開始檢測')
stackless.run()



問題來了，如果我收不到數(shù)據(jù)，我永遠(yuǎn)無法跳回到check()檢測值a了～

我要怎么做才能一邊收包一邊檢測a的值呢??

千年沉寂

沒用過stackless模塊，但按線程的基本原理理解，udp()接收數(shù)據(jù)和check()是兩個線程，它們是并行的，應(yīng)該不會出現(xiàn)check()無法運(yùn)行的情況。

PS： check()函數(shù)的變量a和udp()函數(shù)的變量a都是局部變量，作用范圍只在本函數(shù)內(nèi)，兩個a是獨(dú)立不相關(guān)的，盡管它們變量名一樣。

zengleo

謝謝樓上的


現(xiàn)在問題是

我的線程
是這樣的哦

如果udp收不到包
就永遠(yuǎn)無法去檢測a的值了

ps:
這兩個a其實(shí)沒有什么關(guān)系的,是我順手寫成這樣的～

[ 本帖最后由 zengleo 于 2009-5-7 01:23 編輯 ]

zengleo

哪位大俠幫忙想想辦法啊～～～

knift

recvfrom會造成系統(tǒng)阻塞,stackless在這種情況下是無能為力的~~~stackless終究只是甜點(diǎn)...  
要達(dá)到你這個目的還是回到傳統(tǒng)進(jìn)程 or 線程模型吧!

zengleo

能不能在socket上面做文章呢～
比如做成 非阻塞的～

zengleo

原帖由 knift 于 2009-5-7 17:45 發(fā)表
recvfrom會造成系統(tǒng)阻塞,stackless在這種情況下是無能為力的~~~stackless終究只是甜點(diǎn)...  
要達(dá)到你這個目的還是回到傳統(tǒng)進(jìn)程 or 線程模型吧!

傳統(tǒng)的怎么實(shí)現(xiàn)？？？

seewind

看來樓上幾位對stackless還不了解。stackless是微線程，并非真實(shí)的線程，而且線程間也不是并行執(zhí)行的。
如果有心學(xué)習(xí)這個強(qiáng)大的微線程技術(shù)，可以svn下這些例子回來學(xué)習(xí)：
http://stacklessexamples.googlecode.com/svn/trunk
樓主的問題，在這些例子里面有解決辦法。就是examples\networking\stacklesssocket.py。
這個單元是模擬普通的socket.py，用select異步模式代替阻塞模式。

zengleo

謝謝��！

zengleo

能不能再指點(diǎn)一下我�。。。。�