Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/stefan-niedermann/nextcloud-deck.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat (limited to 'app/src/main/java/it/niedermann/nextcloud/deck/util/ExecutorServiceProvider.java')
-rw-r--r--app/src/main/java/it/niedermann/nextcloud/deck/util/ExecutorServiceProvider.java19
1 files changed, 7 insertions, 12 deletions
diff --git a/app/src/main/java/it/niedermann/nextcloud/deck/util/ExecutorServiceProvider.java b/app/src/main/java/it/niedermann/nextcloud/deck/util/ExecutorServiceProvider.java
index dc5e30bac..8ef8c5771 100644
--- a/app/src/main/java/it/niedermann/nextcloud/deck/util/ExecutorServiceProvider.java
+++ b/app/src/main/java/it/niedermann/nextcloud/deck/util/ExecutorServiceProvider.java
@@ -1,27 +1,22 @@
package it.niedermann.nextcloud.deck.util;
import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
+import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
-/**
- * If we really want <strong>this</strong>, we should default to {@link Executors#newWorkStealingPool()}.
- * Though I recommend to distinguish between blocking threads and non-blocking threads (like network operations), where it does not make sense to limit it to available CPU cores.
- */
-//@Deprecated(forRemoval = true)
public class ExecutorServiceProvider {
-// private static final int NUMBER_OF_CORES = Runtime.getRuntime().availableProcessors();
+ private static final int NUMBER_OF_CORES = Runtime.getRuntime().availableProcessors();
- private static final ExecutorService EXECUTOR =
- Executors.newWorkStealingPool();
-// new ThreadPoolExecutor(NUMBER_OF_CORES>>1, NUMBER_OF_CORES,
-// 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<>());
+ private static final ExecutorService EXECUTOR = new ThreadPoolExecutor(NUMBER_OF_CORES >> 1, NUMBER_OF_CORES,
+ 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<>());
private ExecutorServiceProvider() {
// hide Constructor
}
- public static ExecutorService getExecutorService() {
+ public static ExecutorService getLinkedBlockingQueueExecutor() {
return EXECUTOR;
}
}