gistfile1.py

class AsyncQueue(object):

    def __init__(self):
        self.q = []
        self.ready = Future()

    def push(self, value):
        self.q.append(value)
        yield self.ready(True)

    def get(self):
        while True:
            while self.q:
                yield self.q.pop()
            yield self.ready