diff --git a/microsplit/auxiliary.py b/microsplit/auxiliary.py index bcc48e74efd35b7579d37cd4ec6fe44b36f330ce..48fa6a3f5650fd885b7d9f9f2ea5d636985c5f09 100644 --- a/microsplit/auxiliary.py +++ b/microsplit/auxiliary.py @@ -17,10 +17,9 @@ def partitionning(num_processes): """ Partition the number of threads for writing and fragmenting. """ - read_processes = max(int(num_processes / 3), 2) - write_processes = read_processes - compute_processes = max(num_processes - (write_processes * 2), 1) - return read_processes, write_processes, compute_processes + write_processes = num_processes // 4 + compute_processes = num_processes - (write_processes * 2) + return write_processes, compute_processes def check_data(data): for element in data[0]: