Source code for AFL.automation.EpicsADLiveProcess.CollateDaemon

import threading
import time
from .AreaDetectorLive import AreaDetectorLive



[docs]
class CollateDaemon(threading.Thread):

[docs]
    def __init__(self,app,reduction_queue,**kwargs):
        app.logger.info('Creating CollateDaemon thread')

        threading.Thread.__init__(self,name='CollateDaemon',daemon=True)
        self._stop = False
        self._app = app

        self.reduction_queue = reduction_queue

        self.detector = AreaDetectorLive(**kwargs)



[docs]
    def terminate(self):
        self._app.logger.info('Terminating CollateDaemon thread')
        self._stop = True



[docs]
    def run(self):
        while not self._stop:
            tempval = self.detector.queuehandler()
            if tempval is not None:
                self.reduction_queue.put(tempval)
                self._app.logger.info(f'Got new image {tempval[0]}, placing in reduction queue as item {self.reduction_queue.qsize()}')
            time.sleep(0.001)
        self._app.logger.info('CollateDaemon runloop exiting')