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:
scan (TomwerScanBase) – scan 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