hcp_helpers.py 文件源码

def synchronized( f ):
    '''Synchronization decorator.'''

    lock = Mutex()

    def new_function( *args, **kw ):
        lock.lock()
        try:
            return f( *args, **kw )
        finally:
            lock.unlock()

    return new_function