cap cpu during filtering

This commit is contained in:
Jan 2021-12-09 16:01:57 +01:00
commit 795bf39495

View file

@ -209,7 +209,7 @@ class SegmentedSampleFilterSubprocessor(Subprocessor):
#override #override
def process_info_generator(self): def process_info_generator(self):
for i in range(multiprocessing.cpu_count()): for i in range(min(multiprocessing.cpu_count(),8)):
yield 'CPU%d' % (i), {}, {'samples':self.samples, 'count_xseg_mask':self.count_xseg_mask} yield 'CPU%d' % (i), {}, {'samples':self.samples, 'count_xseg_mask':self.count_xseg_mask}
#override #override