fix a potential dead lock, TaskConvergence when then number of core processor is greater than 4, main thread will be blocked

ztmark · ztmark · commit 538dfe2a7369 · 2018-03-28T18:43:40.000+08:00
diff --git a/src/main/java/br/com/leonardoz/patterns/task_convergence/TaskConvergence.java b/src/main/java/br/com/leonardoz/patterns/task_convergence/TaskConvergence.java
@@ -60,7 +60,7 @@ public class TaskConvergence {
 	public TaskConvergence() {
 		barrier = new CyclicBarrier(CORES, onComplete);
 		synchronizedLinkedList = Collections.synchronizedList(new LinkedList<>());
-		executor = Executors.newFixedThreadPool(4);
+		executor = Executors.newFixedThreadPool(CORES);
 	}
 
 	public void run() {

Original file line number	Diff line number	Diff line change
`@@ -60,7 +60,7 @@ public class TaskConvergence {`
`60`	`60`	`public TaskConvergence() {`
`61`	`61`	`barrier = new CyclicBarrier(CORES, onComplete);`
`62`	`62`	`synchronizedLinkedList = Collections.synchronizedList(new LinkedList<>());`
`63`		`- executor = Executors.newFixedThreadPool(4);`
	`63`	`+ executor = Executors.newFixedThreadPool(CORES);`
`64`	`64`	`}`
`65`	`65`
`66`	`66`	`public void run() {`