tomwer.synctools.stacks.processingstack.FIFO#

class tomwer.synctools.stacks.processingstack.FIFO(process_id=None)#

Processing Queue with a First In, First Out behavior

add(data, configuration=None, callback=None)#

add a scan to process

Parameters:
  • data – data to process

  • configuration – configuration of the process

  • callback – function to call once the processing is Done

append(value)#
can_process_next()#
Returns:

True if the computation thread is ready to compute a new axis position

cancel()#

cancel (abort) processing of given dataset. If dataset is empty then conside this is the current processing that must be cancelled

clear()#
property data_currently_computed: TomwerObject | None#
is_computing()#

Return True if processing thread is running (mean that computation is on going)

pop()#
remove(value)#
sigComputationEnded#

Signal emitted when a computation is ended. First parameter is mandatory and is the scan computed. Second one is an optional FutureTomwerScan

sigComputationStarted#

Signal emitted when a computation is started

stop()#
wait_computation_finished()#

Wait until the computation is finished