root/python/stackless/udp_server.py

#!/usr/bin/env python
#vim:fileencoding=utf-8

import stackless
import sys, stacklesssocket as socket
sys.modules["socket"] = socket

def udp_server(socket_address, handler):
  sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
  sock.bind(socket_address)
  while True:
    (data, address) = sock.recvfrom(8192)
    stackless.tasklet(handler)(sock, data, address)

def udp_handler(sock, data, address):
  import time
  print '%.6f %r %r' % (time.time(), data, address)
  sock.sendto(data, address)    # エコーバック
  #XXX 時間がかかる処理を行う場合は、適宜の次の行をはさむ。
  # stackless.schedule()

def test():
  stackless.tasklet(udp_server)(('0.0.0.0', 2000), udp_handler)
  stackless.run()

if __name__ == '__main__':
  test()