##language:zh
#pragma section-numbers off
##含有章节索引导航的 ZPyUG 文章通用模板
<<TableOfContents>>
## 默许导航,请保留
<<Include(ZPyUGnav)>>


= StacklessPy的Sleep 方式 =

##startInc
{{{
@googlegroups.com>
date	Wed, Feb 4, 2009 at 21:33
subject	[eurasia-users] Re: StopIteration: the main tasklet is receiving without a sender available.
}}}

== eruaisa的 ==
欢迎进入 Stackless Python 的世界!

{{{#!python
import sqlite3, sha
from time import time
from random import random
from sqlite3 import IntegrityError
from stackless import tasklet, schedule, channel

def sleep(sec):
       c = channel()
       while True:
               uid = sha.new('%s' % random()).hexdigest()

               try:
                       cursor.execute(
                               'INSERT INTO hypnus VALUES (?, ?)',
                               (uid, time() + sec) )
                       break
               except IntegrityError:
                       continue

       channels[uid] = c
       c.receive()

def tasklets():
       while True:
               now = time()
               l = cursor.execute(
                       'SELECT id FROM hypnus WHERE timeout<?',
                       (now, ) ).fetchall()
               for i in l:
                       uid = i[0]
                       c = channels[uid]
                       del channels[uid]

                       c.send(None)
               if l:
                       cursor.execute(
                               'DELETE FROM hypnus WHERE timeout<?',
                               (now, ))
               schedule()

cursor = sqlite3.connect(':memory:').cursor()
cursor.execute( ( 'CREATE TABLE IF NOT EXISTS hypnus '
       '(id TEXT PRIMARY KEY, timeout FLOAT NOT NULL)' ) )
cursor.execute('CREATE INDEX idx_timeout on hypnus(timeout)')
channels = {}; tasklet(tasklets)()

__import__('time').sleep = sleep
}}}

=== 官方sleep ===
{{{#!python
import stackless
sleepingTasklets = []
sleepingTicks = 0

def sleep(secondsToWait):
       channel = stackless.channel()
       endTime = sleepingTicks + secondsToWait
       sleepingTasklets.append((endTime, channel))
       sleepingTasklets.sort()
       channel.receive()

def ManageSleepingTasklets():
       global sleepingTicks
       while 1:
               if len(sleepingTasklets):
                       endTime = sleepingTasklets[0][0]
                       while endTime <= sleepingTicks:
                               channel = sleepingTasklets[0][1]
                               del sleepingTasklets[0]
                               channel.send(None)
                               endTime = sleepingTasklets[0][0] # 检查下一个
               sleepingTicks += 1
               print "1 second passed"
               stackless.schedule()

stackless.tasklet(ManageSleepingTasklets)()

}}}

##endInc

----
'''反馈'''

创建 by -- ZoomQuiet [<<DateTime(2009-02-04T13:47:49Z)>>]