ž
ÿ f‘L c @ sØ d Z d d l Z d d l Z d d l Z d d l Z d Z d Z d Z d Z d Z d Z
d Z d
Z d Z
e e
e e e
g Z i d e 6d
e
6d e 6d e 6d e
6Z e j d ƒ Z Gd d „ d e ƒ Z Gd d „ d e ƒ Z Gd d „ d e ƒ Z Gd d „ d e ƒ Z Gd d „ d e ƒ Z Gd d „ d e ƒ Z Gd d „ d e ƒ Z Gd d „ d e ƒ Z d! d" „ Z d d# d$ „ Z e j d% d& ƒ Z d e d' d( „ Z! Gd) d* „ d* e ƒ Z" Gd+ d, „ d, e ƒ Z# d S(- u" Brian Quinlan (brian@sweetapp.com)i Nu FIRST_COMPLETEDu FIRST_EXCEPTIONu
ALL_COMPLETEDu
_AS_COMPLETEDu PENDINGu RUNNINGu CANCELLEDu CANCELLED_AND_NOTIFIEDu FINISHEDu pendingu runningu cancelledu finishedu concurrent.futuresc B s | Ee Z d Z d Z d S( u Erroru- Base class for all future-related exceptions.N( u __name__u
__module__u __qualname__u __doc__( u
__locals__( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu Error, s u Errorc B s | Ee Z d Z d Z d S( u CancelledErroru The Future was cancelled.N( u __name__u
__module__u __qualname__u __doc__( u
__locals__( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu CancelledError0 s u CancelledErrorc B s | Ee Z d Z d Z d S( u TimeoutErroru* The operation exceeded the given deadline.N( u __name__u
__module__u __qualname__u __doc__( u
__locals__( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu TimeoutError4 s u TimeoutErrorc B sJ | Ee Z d Z d Z d d „ Z d d „ Z d d „ Z d d „ Z d
S( u _Waiteru; Provides the event that wait() and as_completed() block on.c C s t j ƒ | _ g | _ d S( N( u threadingu Eventu eventu finished_futures( u self( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu __init__: s u _Waiter.__init__c C s | j j | ƒ d S( N( u finished_futuresu append( u selfu future( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu
add_result> s u _Waiter.add_resultc C s | j j | ƒ d S( N( u finished_futuresu append( u selfu future( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu
add_exceptionA s u _Waiter.add_exceptionc C s | j j | ƒ d S( N( u finished_futuresu append( u selfu future( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu
add_cancelledD s u _Waiter.add_cancelledN( u __name__u
__module__u __qualname__u __doc__u __init__u
add_resultu
add_exceptionu
add_cancelled( u
__locals__( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu _Waiter8 s
u _Waiterc sb | Ee Z d Z d Z ‡ f d d † Z ‡ f d d † Z ‡ f d d † Z ‡ f d d † Z ‡ S(
u _AsCompletedWaiteru Used by as_completed().c s& t t | ƒ j ƒ t j ƒ | _ d S( N( u superu _AsCompletedWaiteru __init__u threadingu Locku lock( u self( u __class__( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu __init__J s u _AsCompletedWaiter.__init__c
s7 | j ( t t | ƒ j | ƒ | j j ƒ Wd QXd S( N( u locku superu _AsCompletedWaiteru
add_resultu eventu set( u selfu future( u __class__( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu
add_resultN s
u _AsCompletedWaiter.add_resultc
s7 | j ( t t | ƒ j | ƒ | j j ƒ Wd QXd S( N( u locku superu _AsCompletedWaiteru
add_exceptionu eventu set( u selfu future( u __class__( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu
add_exceptionS s
u _AsCompletedWaiter.add_exceptionc
s7 | j ( t t | ƒ j | ƒ | j j ƒ Wd QXd S( N( u locku superu _AsCompletedWaiteru
add_cancelledu eventu set( u selfu future( u __class__( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu
add_cancelledX s
u _AsCompletedWaiter.add_cancelled( u __name__u
__module__u __qualname__u __doc__u __init__u
add_resultu
add_exceptionu
add_cancelled( u
__locals__( ( u __class__u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu _AsCompletedWaiterG s
u _AsCompletedWaiterc sP | Ee Z d Z d Z ‡ f d d † Z ‡ f d d † Z ‡ f d d † Z ‡ S( u _FirstCompletedWaiteru* Used by wait(return_when=FIRST_COMPLETED).c s! t ƒ j | ƒ | j j ƒ d S( N( u superu
add_resultu eventu set( u selfu future( u __class__( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu
add_result` s u _FirstCompletedWaiter.add_resultc s! t ƒ j | ƒ | j j ƒ d S( N( u superu
add_exceptionu eventu set( u selfu future( u __class__( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu
add_exceptiond s u# _FirstCompletedWaiter.add_exceptionc s! t ƒ j | ƒ | j j ƒ d S( N( u superu
add_cancelledu eventu set( u selfu future( u __class__( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu
add_cancelledh s u# _FirstCompletedWaiter.add_cancelled( u __name__u
__module__u __qualname__u __doc__u
add_resultu
add_exceptionu
add_cancelled( u
__locals__( ( u __class__u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu _FirstCompletedWaiter] s u _FirstCompletedWaiterc sn | Ee Z d Z d Z ‡ f d d † Z d d „ Z ‡ f d d † Z ‡ f d d † Z ‡ f d
d † Z ‡ S( u _AllCompletedWaiteru< Used by wait(return_when=FIRST_EXCEPTION and ALL_COMPLETED).c s2 | | _ | | _ t j ƒ | _ t ƒ j ƒ d S( N( u num_pending_callsu stop_on_exceptionu threadingu Locku locku superu __init__( u selfu num_pending_callsu stop_on_exception( u __class__( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu __init__o s u _AllCompletedWaiter.__init__c
C s< | j - | j d 8_ | j s2 | j j ƒ n Wd QXd S( Ni ( u locku num_pending_callsu eventu set( u self( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu _decrement_pending_callsu s
u, _AllCompletedWaiter._decrement_pending_callsc s t ƒ j | ƒ | j ƒ d S( N( u superu
add_resultu _decrement_pending_calls( u selfu future( u __class__( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu
add_result{ s u _AllCompletedWaiter.add_resultc s7 t ƒ j | ƒ | j r) | j j ƒ n
| j ƒ d S( N( u superu
add_exceptionu stop_on_exceptionu eventu setu _decrement_pending_calls( u selfu future( u __class__( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu
add_exception s u! _AllCompletedWaiter.add_exceptionc s t ƒ j | ƒ | j ƒ d S( N( u superu
add_cancelledu _decrement_pending_calls( u selfu future( u __class__( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu
add_cancelled† s u! _AllCompletedWaiter.add_cancelled( u __name__u
__module__u __qualname__u __doc__u __init__u _decrement_pending_callsu
add_resultu
add_exceptionu
add_cancelled( u
__locals__( ( u __class__u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu _AllCompletedWaiterl s u _AllCompletedWaiterc B s> | Ee Z d Z d Z d d „ Z d d „ Z d d „ Z d S( u _AcquireFuturesuD A context manager that does an ordered acquire of Future conditions.c C s t | d t ƒ| _ d S( Nu key( u sortedu idu futures( u selfu futures( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu __init__ s u _AcquireFutures.__init__c C s% x | j D] } | j j ƒ q
Wd S( N( u futuresu
_conditionu acquire( u selfu future( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu __enter__ s u _AcquireFutures.__enter__c G s% x | j D] } | j j ƒ q
Wd S( N( u futuresu
_conditionu release( u selfu argsu future( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu __exit__” s u _AcquireFutures.__exit__N( u __name__u
__module__u __qualname__u __doc__u __init__u __enter__u __exit__( u
__locals__( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu _AcquireFuturesŠ s u _AcquireFuturesc C sÀ | t k r t ƒ } nƒ | t k r0 t ƒ } nk t d d „ | Dƒ ƒ } | t k rj t | d d ƒ} n1 | t k r‹ t | d d ƒ} n t
d | ƒ ‚ x | D] } | j j | ƒ q¢ W| S( Nc s s$ | ] } | j t t g k Vq d S( N( u _stateu CANCELLED_AND_NOTIFIEDu FINISHED( u .0u f( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu Ÿ s u. _create_and_install_waiters..u stop_on_exceptionu Invalid return condition: %rTF(
u
_AS_COMPLETEDu _AsCompletedWaiteru FIRST_COMPLETEDu _FirstCompletedWaiteru sumu FIRST_EXCEPTIONu _AllCompletedWaiteru Trueu
ALL_COMPLETEDu Falseu
ValueErroru _waitersu append( u fsu return_whenu waiteru
pending_countu f( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu _create_and_install_waiters˜ s
u _create_and_install_waitersc c sx | d k r | t j ƒ } n t | ƒ } t | ƒ 7 t d d „ | Dƒ ƒ } | | } t | t ƒ } Wd QXzß x | D] } | Vqz Wx | rM| d k r§ d } nA | t j ƒ } | d k rè t d t | ƒ t | ƒ f ƒ ‚ n | j j | ƒ | j
$ | j } g | _ | j j ƒ Wd QXx | D] } | V| j
| ƒ q.WqŒ WWd x | D] } | j j
| ƒ qYWXd S( un An iterator over the given futures that yields each as it completes.
Args:
fs: The sequence of Futures (possibly created by different Executors) to
iterate over.
timeout: The maximum number of seconds to wait. If None, then there
is no limit on the wait time.
Returns:
An iterator that yields the given Futures as they complete (finished or
cancelled). If any given Futures are duplicated, they will be returned
once.
Raises:
TimeoutError: If the entire result iterator could not be generated
before the given timeout.
c s s* | ] } | j t t g k r | Vq d S( N( u _stateu CANCELLED_AND_NOTIFIEDu FINISHED( u .0u f( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu Å s u as_completed..Ni u %d (of %d) futures unfinished( u Noneu timeu setu _AcquireFuturesu _create_and_install_waitersu
_AS_COMPLETEDu TimeoutErroru lenu eventu waitu locku finished_futuresu clearu removeu _waiters( u fsu timeoutu end_timeu finishedu pendingu waiteru futureu wait_timeoutu f( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu as_completed s:
u as_completedu DoneAndNotDoneFuturesu
done not_donec C s" t | ƒ ¼ t d d „ | Dƒ ƒ } t | ƒ | } | t k rU | rU t | | ƒ S| t k r | r t d d „ | Dƒ ƒ r t | | ƒ Sn t | ƒ t | ƒ k rµ t | | ƒ St | | ƒ } Wd QX| j j | ƒ x | D] } | j
j | ƒ qá W| j | j
ƒ t | t | ƒ | ƒ S( u Wait for the futures in the given sequence to complete.
Args:
fs: The sequence of Futures (possibly created by different Executors) to
wait upon.
timeout: The maximum number of seconds to wait. If None, then there
is no limit on the wait time.
return_when: Indicates when this function should return. The options
are:
FIRST_COMPLETED - Return when any future finishes or is
cancelled.
FIRST_EXCEPTION - Return when any future finishes by raising an
exception. If no future raises an exception
then it is equivalent to ALL_COMPLETED.
ALL_COMPLETED - Return when all futures finish or are cancelled.
Returns:
A named 2-tuple of sets. The first set, named 'done', contains the
futures that completed (is finished or cancelled) before the wait
completed. The second set, named 'not_done', contains uncompleted
futures.
c s s* | ] } | j t t g k r | Vq d S( N( u _stateu CANCELLED_AND_NOTIFIEDu FINISHED( u .0u f( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu s u wait..c s s4 | ]* } | j ƒ r | j ƒ d k r | Vq d S( N( u cancelledu exceptionu None( u .0u f( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu s N( u _AcquireFuturesu setu FIRST_COMPLETEDu DoneAndNotDoneFuturesu FIRST_EXCEPTIONu anyu lenu _create_and_install_waitersu eventu waitu _waitersu removeu updateu finished_futures( u fsu timeoutu return_whenu doneu not_doneu waiteru f( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu waité s
u waitc B sÈ | Ee Z d Z d Z d d „ Z d d „ Z d d „ Z d d „ Z d
d „ Z d d
„ Z d d „ Z
d d „ Z d d „ Z d d d „ Z d d d „ Z d d „ Z d d „ Z d d „ Z d S( u Futureu5 Represents the result of an asynchronous computation.c C s@ t j ƒ | _ t | _ d | _ d | _ g | _ g | _ d S( u8 Initializes the future. Should not be called by clients.N(
u threadingu Conditionu
_conditionu PENDINGu _stateu Noneu _resultu
_exceptionu _waitersu _done_callbacks( u self( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu __init__ s u Future.__init__c C sK xD | j D]9 } y | | ƒ Wq
t k
rB t j d | ƒ Yq
Xq
Wd S( Nu! exception calling callback for %r( u _done_callbacksu Exceptionu LOGGERu exception( u selfu callback( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu _invoke_callbacks% s
u Future._invoke_callbacksc C sª | j › | j t k r | j rO d t t | ƒ ƒ t | j | j j j f Sd t t | ƒ ƒ t | j | j j j f Sn d t t | ƒ ƒ t | j f SWd QXd S( Nu! u# u (
u
_conditionu _stateu FINISHEDu
_exceptionu hexu idu _STATE_TO_DESCRIPTION_MAPu __class__u __name__u _result( u self( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu __repr__, s
u Future.__repr__c
C sf | j M | j t t g k r# d S| j t t g k r< d St | _ | j j ƒ Wd QX| j ƒ d S( u» Cancel the future if possible.
Returns True if the future was cancelled, False otherwise. A future
cannot be cancelled if it is running or has already completed.
NFT(
u
_conditionu _stateu RUNNINGu FINISHEDu Falseu CANCELLEDu CANCELLED_AND_NOTIFIEDu Trueu
notify_allu _invoke_callbacks( u self( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu cancel= s
u
Future.cancelc
C s' | j | j t t g k SWd QXd S( u( Return True if the future was cancelled.N( u
_conditionu _stateu CANCELLEDu CANCELLED_AND_NOTIFIED( u self( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu cancelledP s
u Future.cancelledc C s! | j | j t k SWd QXd S( u1 Return True if the future is currently executing.N( u
_conditionu _stateu RUNNING( u self( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu runningU s
u Future.runningc C s* | j | j t t t g k SWd QXd S( u> Return True of the future was cancelled or finished executing.N( u
_conditionu _stateu CANCELLEDu CANCELLED_AND_NOTIFIEDu FINISHED( u self( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu doneZ s
u Future.donec C s | j r | j ‚ n | j Sd S( N( u
_exceptionu _result( u self( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu __get_result_ s u Future.__get_resultc C sJ | j 1 | j t t t g k r6 | j j | ƒ d SWd QX| | ƒ d S( u% Attaches a callable that will be called when the future finishes.
Args:
fn: A callable that will be called with this future as its only
argument when the future completes or is cancelled. The callable
will always be called by a thread in the same process in which
it was added. If the future has already completed or been
cancelled then the callable will be called immediately. These
callables are called in the order that they were added.
N( u
_conditionu _stateu CANCELLEDu CANCELLED_AND_NOTIFIEDu FINISHEDu _done_callbacksu append( u selfu fn( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu add_done_callbacke s
u Future.add_done_callbackc
C s¡ | j ’ | j t t g k r+ t ƒ ‚ n | j t k rD | j ƒ S| j j | ƒ | j t t g k ru t ƒ ‚ n" | j t k rŽ | j ƒ St ƒ ‚ Wd QXd S( uB Return the result of the call that the future represents.
Args:
timeout: The number of seconds to wait for the result if the future
isn't done. If None, then there is no limit on the wait time.
Returns:
The result of the call that the future represents.
Raises:
CancelledError: If the future was cancelled.
TimeoutError: If the future didn't finish executing before the given
timeout.
Exception: If the call raised then that exception will be raised.
N( u
_conditionu _stateu CANCELLEDu CANCELLED_AND_NOTIFIEDu CancelledErroru FINISHEDu _Future__get_resultu waitu TimeoutError( u selfu timeout( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu resultv s
u
Future.resultc
C s› | j Œ | j t t g k r+ t ƒ ‚ n | j t k rA | j S| j j | ƒ | j t t g k rr t ƒ ‚ n | j t k rˆ | j St ƒ ‚ Wd QXd S( uU Return the exception raised by the call that the future represents.
Args:
timeout: The number of seconds to wait for the exception if the
future isn't done. If None, then there is no limit on the wait
time.
Returns:
The exception raised by the call that the future represents or None
if the call completed without raising.
Raises:
CancelledError: If the future was cancelled.
TimeoutError: If the future didn't finish executing before the given
timeout.
N( u
_conditionu _stateu CANCELLEDu CANCELLED_AND_NOTIFIEDu CancelledErroru FINISHEDu
_exceptionu waitu TimeoutError( u selfu timeout( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu exception• s
u Future.exceptionc C s• | j † | j t k rG t | _ x | j D] } | j | ƒ q, Wd S| j t k rc t | _ d St
j d t | ƒ | j ƒ t
d ƒ ‚ Wd QXd S( u¸ Mark the future as running or process any cancel notifications.
Should only be used by Executor implementations and unit tests.
If the future has been cancelled (cancel() was called and returned
True) then any threads waiting on the future completing (though calls
to as_completed() or wait()) are notified and False is returned.
If the future was not cancelled then it is put in the running state
(future calls to running() will return True) and True is returned.
This method should be called by Executor implementations before
executing the work associated with this future. If this method returns
False then the work should not be executed.
Returns:
False if the Future was cancelled, True otherwise.
Raises:
RuntimeError: if this method was already called or if set_result()
or set_exception() was called.
u! Future %s in unexpected state: %su Future in unexpected stateNFT( u
_conditionu _stateu CANCELLEDu CANCELLED_AND_NOTIFIEDu _waitersu
add_cancelledu Falseu PENDINGu RUNNINGu Trueu LOGGERu criticalu idu RuntimeError( u selfu waiter( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu set_running_or_notify_cancel· s
u# Future.set_running_or_notify_cancelc
C s^ | j E | | _ t | _ x | j D] } | j | ƒ q& W| j j ƒ Wd QX| j ƒ d S( u‹ Sets the return value of work associated with the future.
Should only be used by Executor implementations and unit tests.
N( u
_conditionu _resultu FINISHEDu _stateu _waitersu
add_resultu
notify_allu _invoke_callbacks( u selfu resultu waiter( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu
set_resultß s
u Future.set_resultc
C s^ | j E | | _ t | _ x | j D] } | j | ƒ q& W| j j ƒ Wd QX| j ƒ d S( u Sets the result of the future as being the given exception.
Should only be used by Executor implementations and unit tests.
N( u
_conditionu
_exceptionu FINISHEDu _stateu _waitersu
add_exceptionu
notify_allu _invoke_callbacks( u selfu exceptionu waiter( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu
set_exceptionì s
u Future.set_exceptionN( u __name__u
__module__u __qualname__u __doc__u __init__u _invoke_callbacksu __repr__u cancelu cancelledu runningu doneu _Future__get_resultu add_done_callbacku Noneu resultu exceptionu set_running_or_notify_cancelu
set_resultu
set_exception( u
__locals__( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu Future s " (
u Futurec B s_ | Ee Z d Z d Z d d „ Z d d
d d „ Z d d d „ Z d d
„ Z d d „ Z
d
S( u ExecutoruC This is an abstract base class for concrete asynchronous executors.c O s
t ƒ ‚ d S( u Submits a callable to be executed with the given arguments.
Schedules the callable to be executed as fn(*args, **kwargs) and returns
a Future instance representing the execution of the callable.
Returns:
A Future representing the given call.
N( u NotImplementedError( u selfu fnu argsu kwargs( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu submitü s u Executor.submitu timeoutc s` ˆ d k r ˆ t j ƒ ‰ n ‡ ‡ f d d † t | Œ Dƒ ‰ ‡ ‡ ‡ f d d † } | ƒ S( u} Returns a iterator equivalent to map(fn, iter).
Args:
fn: A callable that will take as many arguments as there are
passed iterables.
timeout: The maximum number of seconds to wait. If None, then there
is no limit on the wait time.
Returns:
An iterator equivalent to: map(func, *iterables) but the calls may
be evaluated out-of-order.
Raises:
TimeoutError: If the entire result iterator could not be generated
before the given timeout.
Exception: If fn(*args) raises for any values.
c s" g | ] } ˆ j ˆ | Œ ‘ q S( ( u submit( u .0u args( u fnu self( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu
s u Executor.map..c 3 sj zG x@ ˆ D]8 } ˆ d k r* | j ƒ Vq
| j ˆ t j ƒ ƒ Vq
WWd x ˆ D] } | j ƒ qQ WXd S( N( u Noneu resultu timeu cancel( u future( u end_timeu fsu timeout( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu result_iterator s
u% Executor.map..result_iteratorN( u Noneu timeu zip( u selfu fnu timeoutu iterablesu result_iterator( ( u end_timeu fnu fsu selfu timeoutu= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu map s
"
u Executor.mapc C s d S( u‹ Clean-up the resources associated with the Executor.
It is safe to call this method several times. Otherwise, no other
methods can be called after this one.
Args:
wait: If True then shutdown will not return until all running
futures have finished executing and the resources used by the
executor have been reclaimed.
N( ( u selfu wait( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu shutdown, s u Executor.shutdownc C s | S( N( ( u self( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu __enter__9 s u Executor.__enter__c C s | j d d ƒ d S( Nu waitTF( u shutdownu Trueu False( u selfu exc_typeu exc_valu exc_tb( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu __exit__< s u Executor.__exit__NT( u __name__u
__module__u __qualname__u __doc__u submitu Noneu mapu Trueu shutdownu __enter__u __exit__( u
__locals__( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu Executorù s %
u Executor($ u
__author__u collectionsu loggingu threadingu timeu FIRST_COMPLETEDu FIRST_EXCEPTIONu
ALL_COMPLETEDu
_AS_COMPLETEDu PENDINGu RUNNINGu CANCELLEDu CANCELLED_AND_NOTIFIEDu FINISHEDu _FUTURE_STATESu _STATE_TO_DESCRIPTION_MAPu getLoggeru LOGGERu Exceptionu Erroru CancelledErroru TimeoutErroru objectu _Waiteru _AsCompletedWaiteru _FirstCompletedWaiteru _AllCompletedWaiteru _AcquireFuturesu _create_and_install_waitersu Noneu as_completedu
namedtupleu DoneAndNotDoneFuturesu waitu Futureu Executor( ( ( u= /opt/alt/python33/lib64/python3.3/concurrent/futures/_base.pyu sP
: 0à