diff options
author | Jacek <jacek.poreda@sonarsource.com> | 2019-10-21 15:49:34 -0500 |
---|---|---|
committer | SonarTech <sonartech@sonarsource.com> | 2019-11-12 20:21:06 +0100 |
commit | fc3085b6cb8e80b93842b9742794a11414d11198 (patch) | |
tree | 809abed588cbdbcdfc35d61c4b317e85e4a767b6 /server/sonar-ce | |
parent | ef59775a55e42caf1cfe6c5064458d15b1890747 (diff) | |
download | sonarqube-fc3085b6cb8e80b93842b9742794a11414d11198.tar.gz sonarqube-fc3085b6cb8e80b93842b9742794a11414d11198.zip |
SONAR-12383 Selenide update to 5.2.3 and Guava update to 28.1-jre
Diffstat (limited to 'server/sonar-ce')
-rw-r--r-- | server/sonar-ce/src/main/java/org/sonar/ce/taskprocessor/CeProcessingSchedulerImpl.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/server/sonar-ce/src/main/java/org/sonar/ce/taskprocessor/CeProcessingSchedulerImpl.java b/server/sonar-ce/src/main/java/org/sonar/ce/taskprocessor/CeProcessingSchedulerImpl.java index f75d8aebe9e..5325dd426c5 100644 --- a/server/sonar-ce/src/main/java/org/sonar/ce/taskprocessor/CeProcessingSchedulerImpl.java +++ b/server/sonar-ce/src/main/java/org/sonar/ce/taskprocessor/CeProcessingSchedulerImpl.java @@ -23,6 +23,7 @@ import com.google.common.util.concurrent.FutureCallback; import com.google.common.util.concurrent.Futures; import com.google.common.util.concurrent.ListenableFuture; import com.google.common.util.concurrent.ListenableScheduledFuture; +import com.google.common.util.concurrent.MoreExecutors; import java.util.Arrays; import java.util.concurrent.TimeUnit; import javax.annotation.CheckForNull; @@ -68,7 +69,7 @@ public class CeProcessingSchedulerImpl implements CeProcessingScheduler { public void startScheduling() { for (ChainingCallback chainingCallback : chainingCallbacks) { ListenableScheduledFuture<CeWorker.Result> future = executorService.schedule(chainingCallback.worker, delayBetweenEnabledTasks, timeUnit); - addCallback(future, chainingCallback); + addCallback(future, chainingCallback, MoreExecutors.directExecutor()); } } @@ -200,7 +201,7 @@ public class CeProcessingSchedulerImpl implements CeProcessingScheduler { private void addCallback() { if (workerFuture != null) { - Futures.addCallback(workerFuture, this); + Futures.addCallback(workerFuture, this, MoreExecutors.directExecutor()); } } |