In response to http://emptysqua.re/blog/tornado-locks-and-queues/

test_condition.py

#!/usr/bin/env python


from __future__ import print_function

from circuits import Component, Debugger, Event


class condition(Event):
    """condition Event"""


class waiter(Event):
    """waiter Event"""


class notifier(Event):
    """notifier Event"""


class App(Component):

    def started(self, *args):
        self.fire(waiter())
        yield

        self.fire(notifier())
        yield

        raise SystemExit(0)

    def waiter(self):
        print("I'll wait right here")
        yield self.wait("condition")
        print("I'm done waiting")

    def notifier(self):
        print("About to notify")
        self.fire(condition())
        print("Done notifying")

    def generate_events(self, event):
        print(".")
        event.reduce_time_left(0.1)


(App() + Debugger()).run()

test_queue.py

#!/usr/bin/env python


from __future__ import print_function

from circuits import Component, Debugger, Event


class producer(Event):
    """producer Event"""


class work(Event):
    """work Event"""


class Consumer(Component):

    def work(self, i):
        print("Doing work on {0:d}".format(i))
        # XXX: We don't have an asynchronous sleep() :)


class App(Component):

    def started(self, *args):
        Consumer().register(self)

        self.fire(producer())
        yield

        raise SystemExit(0)

    def producer(self):
        for i in range(4):
            self.fire(work(i))
            print("Put {0:d}".format(i))


(App() + Debugger()).run()

And just for good measure; we're just implemented [async sleep] for circuits: circuits/circuits#62