Back to index

python3.2  3.2.2
Public Member Functions | Public Attributes | Private Member Functions
concurrent.futures._base._AllCompletedWaiter Class Reference
Inheritance diagram for concurrent.futures._base._AllCompletedWaiter:
Inheritance graph
[legend]
Collaboration diagram for concurrent.futures._base._AllCompletedWaiter:
Collaboration graph
[legend]

List of all members.

Public Member Functions

def __init__
def add_result
def add_exception
def add_cancelled

Public Attributes

 num_pending_calls
 stop_on_exception
 event
 finished_futures
_PyObject_HEAD_EXTRA Py_ssize_t ob_refcnt
struct _typeobjectob_type

Private Member Functions

def _decrement_pending_calls

Detailed Description

Used by wait(return_when=FIRST_EXCEPTION and ALL_COMPLETED).

Definition at line 109 of file _base.py.


Constructor & Destructor Documentation

def concurrent.futures._base._AllCompletedWaiter.__init__ (   self,
  num_pending_calls,
  stop_on_exception 
)

Definition at line 112 of file _base.py.

00112 
00113     def __init__(self, num_pending_calls, stop_on_exception):
00114         self.num_pending_calls = num_pending_calls
00115         self.stop_on_exception = stop_on_exception
00116         super().__init__()

Here is the caller graph for this function:


Member Function Documentation

Definition at line 117 of file _base.py.

00117 
00118     def _decrement_pending_calls(self):
00119         self.num_pending_calls -= 1
00120         if not self.num_pending_calls:
00121             self.event.set()

Here is the caller graph for this function:

Reimplemented from concurrent.futures._base._Waiter.

Definition at line 133 of file _base.py.

00133 
00134     def add_cancelled(self, future):
00135         super().add_cancelled(future)
00136         self._decrement_pending_calls()

Here is the call graph for this function:

Reimplemented from concurrent.futures._base._Waiter.

Definition at line 126 of file _base.py.

00126 
00127     def add_exception(self, future):
00128         super().add_exception(future)
00129         if self.stop_on_exception:
00130             self.event.set()
00131         else:
00132             self._decrement_pending_calls()

Here is the call graph for this function:

Reimplemented from concurrent.futures._base._Waiter.

Definition at line 122 of file _base.py.

00122 
00123     def add_result(self, future):
00124         super().add_result(future)
00125         self._decrement_pending_calls()

Here is the call graph for this function:


Member Data Documentation

Definition at line 60 of file _base.py.

Definition at line 61 of file _base.py.

Definition at line 113 of file _base.py.

Definition at line 107 of file object.h.

struct _typeobject* _object::ob_type [inherited]

Definition at line 108 of file object.h.

Definition at line 114 of file _base.py.


The documentation for this class was generated from the following file: