StatisticsManagerThread.py 文件源码

def __init__(self, opts):
            self.opts = opts
        self.mode = None
        self.dic_stats = {}
        self.debug = False
        self.labels = self.opts['labels']
        self.colorsM = self.opts['colormap']
        self.LUT = fromHEX2RGB(self.colorsM)
        self.L = len(self.labels)
        self.last_net = []

        self.listManagers = self.opts['bmanagers']
        self.num_random_imgs = self.opts['samples.vis']
        self.policy = self.opts['policy']

        self.listSampleImages = []
        if(self.policy == 'fixed'):
            for i in range(len(self.listManagers)):
                self.listSampleImages.append(self.listManagers[i].getRandomSamples(self.num_random_imgs[i]))

        self.messages_queue = JoinableQueue()
        self.results_queue = JoinableQueue()
        self.inner_process = Process(target=self.dummy, args=(self.messages_queue, self.results_queue))
            self.inner_process.start()

    # --------------------------------: