tasking for n threads should give you n threads in NanoScheduler, not n - 1
This commit is contained in:
parent
1212dfd2ef
commit
544740d45d
|
|
@ -80,7 +80,7 @@ public class NanoScheduler<InputType, MapType, ReduceType> {
|
|||
this.mapGroupSize = mapGroupSize;
|
||||
}
|
||||
|
||||
this.executor = nThreads == 1 ? null : Executors.newFixedThreadPool(nThreads - 1);
|
||||
this.executor = nThreads == 1 ? null : Executors.newFixedThreadPool(nThreads);
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
|
|||
Loading…
Reference in New Issue