Commit 3788f2c3 authored by Kristof Szabados's avatar Kristof Szabados
Browse files

improved concurrency handling for collection shared between threads.


Signed-off-by: Kristof Szabados's avatarKristof Szabados <Kristof.Szabados@ericsson.com>
parent 19d0490a
......@@ -16,6 +16,7 @@ import java.util.Map;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
......@@ -149,7 +150,7 @@ public final class BrokenPartsChecker {
modulesToCheckCopy.removeAll(modulesToCheckParallely);
}
final List<Module> modulesBeingChecked = new LinkedList<Module>(modulesToCheckParallely);
final LinkedBlockingDeque<Module> modulesBeingChecked = new LinkedBlockingDeque<Module>(modulesToCheckParallely);
synchronized(modulesToCheckCopy) {
for (final Module module : modulesToCheckParallely) {
......@@ -192,7 +193,7 @@ public final class BrokenPartsChecker {
}
private static void addToExecutor(final Module module, final ExecutorService executor, final CountDownLatch latch, final CompilationTimeStamp compilationCounter, final long absoluteStart,
final List<Module> modulesToCheckCopy, final List<Module> modulesBeingChecked, final AtomicInteger activeExecutorCount, final SubMonitor progress) {
final List<Module> modulesToCheckCopy, final LinkedBlockingDeque<Module> modulesBeingChecked, final AtomicInteger activeExecutorCount, final SubMonitor progress) {
executor.execute(new Runnable() {
@Override
public void run() {
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment