Welcome, guest | Sign In | My Account | Store | Cart
import nanothreads
import time
import sys

def task_1():
    while True:
        print "Performing work in task_1"
        yield nanothreads.CONTINUE()
        #yielding nanothreads.UNBLOCK will perform 
        #the next iteration in a seperate thread.
        yield nanothreads.UNBLOCK()
        print "Simulating some Blocking IO..."
        time.sleep(10)
        print "Finished Blocking IO."
        yield nanothreads.CONTINUE()

def task_2():
    while True:
        print "Performing work in task_2"
        yield nanothreads.CONTINUE()
        time.sleep(1)


a = nanothreads.install(task_1())
b = nanothreads.install(task_2())
#defer an exit call for 11 seconds, so this test eventually stops.
nanothreads.defer_for(11, sys.exit)
nanothreads.loop()

History

  • revision 4 (16 years ago)
  • previous revisions are not available