Package uk.ac.gda.analysis.mscan

Class SwmrMalcolmProcessingReader

java.lang.Object

uk.ac.gda.analysis.mscan.SwmrMalcolmProcessingReader

public class SwmrMalcolmProcessingReader
extends Object

Reads a datafile using a Swmr iterator extracting each frame and passing to a list of MalcolmSwmrProcessors.

Constructor Summary

Constructors

Constructor	Description
SwmrMalcolmProcessingReader(Path filepath, int count, int dataRank, Collection<MalcolmSwmrProcessor<?>> procs, String dataPath, String detUidEntry, DatasetCreator datasetConverter)

Method Summary

Modifier and Type	Method	Description
void	abortReading()
void	startAsyncReading()	Start a task asynchronously to iterate over the detector dataset as it is written and pass data to each of the configured processors.
void	waitUntilComplete()	Wait until the reading/processing task is completed

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SwmrMalcolmProcessingReader

public SwmrMalcolmProcessingReader(Path filepath,
 int count,
 int dataRank,
 Collection<MalcolmSwmrProcessor<?>> procs,
 String dataPath,
 String detUidEntry,
 DatasetCreator datasetConverter)

Parameters:

filepath - path for source datafile

count - total number of frames to read

dataRank - rank of dataset to process

procs - processes to receive frames

dataPath - path of the dataset to process

detUidEntry - path of the uid dataset

datasetConverter - applies a transformation to the dataset, if null the original dataset is used as-is

Method Details

startAsyncReading

public void startAsyncReading()

Start a task asynchronously to iterate over the detector dataset as it is written and pass data to each of the configured processors. This method may be called multiple times, the task will only be started/submitted once per lifetime of this object.

waitUntilComplete

public void waitUntilComplete()

Wait until the reading/processing task is completed

abortReading

public void abortReading()