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')[source]

Launch a server and return its client object

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

Bases: object

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

Bases: fluidimage.executors.servers.Worker

class fluidimage.executors.servers.WorkerServer(sleep_time=0.01)[source]

Bases: object

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

Bases: fluidimage.executors.servers.WorkerServer

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, …)