gistfile1.py

from functools import wraps

class Function(Task):
    @staticmethod
    def executor(qname):
        queue = get_queue(qname)
        while True:
            task = queue.get()
            func, args, kwargs = task.funcspec
            task.put(func(*args, **kwargs))
    def __init__(self, func, args, kwargs, qname):
        self.funcspec = func, args, kwargs
        Task.__init__(self, qname)

def atomic(qname):
    def _atomic(func):
        @wraps(func)
        def wrapper(*args, **kwargs):
            return Function(func, args, kwargs, qname).run().get()
        return wrapper
    return _atomic

@atomic('pointless')
def pointless():
    print('Only one of me can run at a time!')