fluidimage.executors.servers

Servers for exec_async_servers (fluidimage.executors.servers)

fluidimage.executors.servers.launch_server(topology, log_path, type_server='multiprocessing', sleep_time=0.1, logging_level='info')

Launch a server and return its client object

class fluidimage.executors.servers.Worker(conn, event_has_to_stop, process)

Bases: object

class fluidimage.executors.servers.WorkerMultiprocessing(conn, event_has_to_stop, process)

Bases: Worker

class fluidimage.executors.servers.WorkerServer(sleep_time=0.01)

Bases: object

class fluidimage.executors.servers.WorkerServerMultiprocessing(conn, event_has_to_stop, topology_cls, params, sleep_time, in_process, log_path, logging_level)

Bases: WorkerServer

log_in_file(*args, sep=' ', end='\n')

Simple write in the log file (without print)

log_in_file_memory_usage(txt, color='OKGREEN', end='\n')

Write the memory usage in the log file

Functions

launch_server(topology, log_path[, ...])

Launch a server and return its client object

Classes

Worker(conn, event_has_to_stop, process)
WorkerMultiprocessing(conn, ...)
WorkerServer([sleep_time])
WorkerServerMultiprocessing(conn, ...)