ffa0db4fdca9cef31a72b35a1f7eef78733f5b0c,glyph/cli/glyph_remote.py,RemoteAssessmentRunner,update_fitness,#RemoteAssessmentRunner#Any#Any#,239

Before Change

        if self.send_all:
            calculate_fitness = self.evaluate_all(population)
        else:
            calculate_fitness = [self.measure(ind) for ind in calculate]

        // save to cache
        for key, fit in zip(map(self._hash, calculate), calculate_fitness):

After Change

            self.queue = MyQueue(self.send, self.recv, self.result_queue, len(calculate))
            thread = Thread(target=self.queue.run)
            thread.start()
            with concurrent.futures.ThreadPoolExecutor(max_workers=len(calculate)) as executor:
                futures = {executor.submit(self.measure, ind): ind for ind in calculate}
                for future in futures:
                    calculate_fitness.append(future.result())
            thread.join()
            //calculate_fitness = [self.measure(ind) for ind in calculate]

        // save to cache

Instances