B `J@sldZddlmZmZmZeZddlZddlZy ddl Z Wne k rTddl Z YnXGdddej Z dS)zPython threading tools.)absolute_importdivisionprint_functionNcs0eZdZdZfddZddZddZZS) WrappedThreadz any N)superr__init__queueQueue_resultactionresult)selfr ) __class__L/home/dcms/DCMS/lib/python3.7/site-packages/ansible_test/_internal/thread.pyrs zWrappedThread.__init__cCs>y|j|dfWn |jdtfYnXdS)z Run action and capture results or exception. Do not override. Do not call directly. Executed by the start() method. N)r putr sysexc_info)r rrrrunszWrappedThread.runcCsD|j\}}|r:tjddkr2|d|dtd||_|S)zj Wait for thread to exit and return the result or raise an exception. :rtype: any rz.raise exception[0], exception[1], exception[2])r getr version_infowith_tracebackexecr )r r exceptionrrrwait_for_result*szWrappedThread.wait_for_result)__name__ __module__ __qualname____doc__rrr __classcell__rr)rrrs r)r __future__rrrtype __metaclass__ threadingrr r ImportErrorThreadrrrrrs