python::AsyncCallThread Namespace Reference

Classes
class	AsyncCallThread
Functions
def	async_call
def	timeout_call

---

Function Documentation

def python::AsyncCallThread::async_call	(		callback,
			func,
			args,
			kwds
	)

Call func asynchronously in a separate thread. See AsyncCallThread class for details.

Definition at line 42 of file AsyncCallThread.py.

00042                                             :
00043     """Call func asynchronously in a separate thread. See AsyncCallThread class for details."""
00044     t = AsyncCallThread(callback,func,*args,**kwds)
00045     t.start()
00046     return t
00047 
00048 
def timeout_call(caller,func, timeout, *args, **kwds):

def python::AsyncCallThread::timeout_call	(		caller,
			func,
			timeout,
			args,
			kwds
	)

Definition at line 49 of file AsyncCallThread.py.

                                                     :
    def callback(t):
        print 'completed'

    t = AsyncCallThread(callback,func,*args,**kwds)
    t.start()
    time.sleep(1)
    while time.time()-t.start_time < timeout:
        if t.stop_time:
            if t.exception:
                raise t.exception
            else:
                return t.result

        time.sleep(1)

    #  Extension to Kuba's code

    from GBSLogger    import GetLoggerThreshold, Log, logger 
    from GBSUtilities import RemoveChildProcesses
    from GBSTimeStamp import GBSTimeStamp
    
    Log(caller,logger.ERROR,"Timeout reached before asynchronous call ended ...")
    Log(caller,logger.ERROR,"...Attempting to delete child processes to unblock before raising timeout exception...")
    RemoveChildProcesses()    
    raise Exception('timeout!')

---