libtbx.thread_utils
index
/net/chevy/raid1/nat/src/cctbx_project/libtbx/thread_utils.py

 
Modules
       
Queue
libtbx.easy_pickle
libtbx
multiprocessing
libtbx.object_oriented_patterns
os
signal
sys
threading
time
traceback
warnings

 
Classes
       
__builtin__.object
child_process_message
child_process_pipe
stdout_pipe
stdout_pipe_buffered
threading.Thread(threading._Verbose)
file_monitor_thread
process_with_callbacks
queue_monitor_thread
simple_task_thread
thread_with_callback_and_wait

 
class child_process_message(__builtin__.object)
     Methods defined here:
__init__(self, message_type, data)

Data descriptors defined here:
__dict__
dictionary for instance variables (if defined)
__weakref__
list of weak references to the object (if defined)

 
class child_process_pipe(__builtin__.object)
     Methods defined here:
__init__(self, connection_object)
recv(self, *args, **kwds)
send(self, *args, **kwds)
send_confirm_abort(self, info=None)

Data descriptors defined here:
__dict__
dictionary for instance variables (if defined)
__weakref__
list of weak references to the object (if defined)

 
class file_monitor_thread(threading.Thread)
    
Method resolution order:
file_monitor_thread
threading.Thread
threading._Verbose
__builtin__.object

Methods defined here:
__init__(self, dir_name, file_names, callback, sleep_interval=1.0)
exit(self)
run(self)

Methods inherited from threading.Thread:
__repr__(self)
getName(self)
isAlive(self)
isDaemon(self)
is_alive = isAlive(self)
join(self, timeout=None)
setDaemon(self, daemonic)
setName(self, name)
start(self)

Data descriptors inherited from threading.Thread:
daemon
ident
name

Data descriptors inherited from threading._Verbose:
__dict__
dictionary for instance variables (if defined)
__weakref__
list of weak references to the object (if defined)

 
class process_with_callbacks(threading.Thread)
    
Method resolution order:
process_with_callbacks
threading.Thread
threading._Verbose
__builtin__.object

Methods defined here:
__init__(self, target, args=(), kwargs={}, callback_stdout=null(), callback_final=null(), callback_err=null(), callback_abort=null(), callback_other=null(), callback_pause=null(), callback_resume=null(), buffer_stdout=True, sleep_after_start=None)
abort(self, force=False)
kill(self)
# XXX experimental
pause(self)
resume(self)
run(self)
send_signal(self, signal_number)
Signals the process using os.kill, which despite the name, can also
pause or resume processes on Unix.

Methods inherited from threading.Thread:
__repr__(self)
getName(self)
isAlive(self)
isDaemon(self)
is_alive = isAlive(self)
join(self, timeout=None)
setDaemon(self, daemonic)
setName(self, name)
start(self)

Data descriptors inherited from threading.Thread:
daemon
ident
name

Data descriptors inherited from threading._Verbose:
__dict__
dictionary for instance variables (if defined)
__weakref__
list of weak references to the object (if defined)

 
class queue_monitor_thread(threading.Thread)
    
Method resolution order:
queue_monitor_thread
threading.Thread
threading._Verbose
__builtin__.object

Methods defined here:
__init__(self, q, callback, sleep_interval=1.0)
exit(self)
run(self)

Methods inherited from threading.Thread:
__repr__(self)
getName(self)
isAlive(self)
isDaemon(self)
is_alive = isAlive(self)
join(self, timeout=None)
setDaemon(self, daemonic)
setName(self, name)
start(self)

Data descriptors inherited from threading.Thread:
daemon
ident
name

Data descriptors inherited from threading._Verbose:
__dict__
dictionary for instance variables (if defined)
__weakref__
list of weak references to the object (if defined)

 
class simple_task_thread(threading.Thread)
    
Method resolution order:
simple_task_thread
threading.Thread
threading._Verbose
__builtin__.object

Methods defined here:
__init__(self, thread_function, parent_window=None)
exception_raised(self)
get_error(self)
is_complete(self)
run(self)

Methods inherited from threading.Thread:
__repr__(self)
getName(self)
isAlive(self)
isDaemon(self)
is_alive = isAlive(self)
join(self, timeout=None)
setDaemon(self, daemonic)
setName(self, name)
start(self)

Data descriptors inherited from threading.Thread:
daemon
ident
name

Data descriptors inherited from threading._Verbose:
__dict__
dictionary for instance variables (if defined)
__weakref__
list of weak references to the object (if defined)

 
class stdout_pipe(__builtin__.object)
    # fake filehandle, sends data up pipe to parent process
 
  Methods defined here:
__init__(self, connection)
close(self)
flush(self)
write(self, data)

Data descriptors defined here:
__dict__
dictionary for instance variables (if defined)
__weakref__
list of weak references to the object (if defined)

 
class stdout_pipe_buffered(stdout_pipe)
    # this slows down the output so it won't stall a GUI
 
 
Method resolution order:
stdout_pipe_buffered
stdout_pipe
__builtin__.object

Methods defined here:
__del__(self)
__init__(self, *args, **kwds)
close(self)
flush(self)
write(self, data)

Data descriptors inherited from stdout_pipe:
__dict__
dictionary for instance variables (if defined)
__weakref__
list of weak references to the object (if defined)

 
class thread_with_callback_and_wait(threading.Thread)
    
Method resolution order:
thread_with_callback_and_wait
threading.Thread
threading._Verbose
__builtin__.object

Methods defined here:
__init__(self, run, callback, first_callback=None, run_args=(), run_kwds={})
resume(self, last_iteration=False)
run(self)
start_and_wait_for_first_callback(self)

Methods inherited from threading.Thread:
__repr__(self)
getName(self)
isAlive(self)
isDaemon(self)
is_alive = isAlive(self)
join(self, timeout=None)
setDaemon(self, daemonic)
setName(self, name)
start(self)

Data descriptors inherited from threading.Thread:
daemon
ident
name

Data descriptors inherited from threading._Verbose:
__dict__
dictionary for instance variables (if defined)
__weakref__
list of weak references to the object (if defined)

 
Data
        division = _Feature((2, 2, 0, 'alpha', 2), (3, 0, 0, 'alpha', 0), 8192)
max_between_flush = 5
null_callback = null()
wait_before_flush = 0.2