Adds number of DSSC multiprocessing workers

DSSC.py

@@ -45,6 +45,7 @@ class DSSC:
         self.mask = None
         self.max_fraction_memory = 0.8
         self.filter_mask = None
+        self.Nworker = 6
         
         print('DSSC configuration')
         print(f'Topic: {self.topic}')
@@ -308,8 +309,8 @@ class DSSC:
         max_GB = psutil.virtual_memory().available/1024**3
         print(f'max available memory: {max_GB} GB')
         
-        # max_GB / (8byte * 16modules * 128px * 512px * N_pulses)
-        self.chunksize = int(self.max_fraction_memory*max_GB * 1024**3 // (8 * 16 * 128 * 512 * self.fpt))
+        # max_GB / (8byte * Nworker * 128px * 512px * N_pulses)
+        self.chunksize = int(self.max_fraction_memory*max_GB * 1024**3 // (8 * self.Nworker * 128 * 512 * self.fpt))
         
         print('processing', self.chunksize, 'trains per chunk')
                    
@@ -329,9 +330,9 @@ class DSSC:
         timestamp = strftime('%X')
         print(f'start time: {timestamp}')
 
-        with multiprocessing.Pool(16) as pool:
+        with multiprocessing.Pool(self.Nworker) as pool:
             module_data = pool.map(process_one_module, jobs)
-    
+
         print('finished:', strftime('%X'))
     
         # rearange the multiprocessed data