Copernicus  2.0
 All Classes Namespaces Files Functions Variables
cpc.server.queue.exec_thread.TaskExecThread Class Reference
Inheritance diagram for cpc.server.queue.exec_thread.TaskExecThread:

Public Member Functions

def queueNone
 
def doStop
 
def doPause
 
def execLoop
 

Public Attributes

 taskQueue
 
 cmdQueue
 
 lock
 
 stop
 
 pause
 
 thread
 
 waiter
 

Detailed Description

A dataflow task execution thread; executes any tasks that are not 
   commands, and queues commands into a command queue.

Member Function Documentation

def cpc.server.queue.exec_thread.TaskExecThread.doPause (   self,
  waiter 
)
Pause the thread until notified with the condition from init().
   waiter =  a thread waiter object
def cpc.server.queue.exec_thread.TaskExecThread.doStop (   self)
Stop the thread at the next iteration.
def cpc.server.queue.exec_thread.TaskExecThread.execLoop (   self)
The execution loop for the exec thread.
def cpc.server.queue.exec_thread.TaskExecThread.queueNone (   self)

Member Data Documentation

cpc.server.queue.exec_thread.TaskExecThread.cmdQueue
cpc.server.queue.exec_thread.TaskExecThread.lock
cpc.server.queue.exec_thread.TaskExecThread.pause
cpc.server.queue.exec_thread.TaskExecThread.stop
cpc.server.queue.exec_thread.TaskExecThread.taskQueue
cpc.server.queue.exec_thread.TaskExecThread.thread
cpc.server.queue.exec_thread.TaskExecThread.waiter

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