Skip to content

Commit 99bfd69

Browse files
ruichuanIstemi Ekin Akkus
authored andcommitted
modified the thread pool size in DataLayerService for higher concurrency
1 parent c9feab0 commit 99bfd69

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

DataLayerService/src/main/java/org/microfunctions/data_layer/DataLayerServer.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -65,8 +65,8 @@ public class DataLayerServer implements Iface, Callable<Object> {
6565
private static final List<AbstractMap.SimpleEntry<String, Integer>> NO_KEYSPACES = new ArrayList<AbstractMap.SimpleEntry<String, Integer>>(0);
6666
private static final List<String> NO_KEYS = new ArrayList<String>(0);
6767

68-
public static final int DEFAULT_SELECTOR_THREADS = Math.max(2, 2 * Runtime.getRuntime().availableProcessors());
69-
public static final int DEFAULT_WORKER_THREADS = Math.max(4, 4 * Runtime.getRuntime().availableProcessors());
68+
public static final int DEFAULT_SELECTOR_THREADS = 50; //Math.max(2, 2 * Runtime.getRuntime().availableProcessors());
69+
public static final int DEFAULT_WORKER_THREADS = 100; //Math.max(4, 4 * Runtime.getRuntime().availableProcessors());
7070
public static final int DEFAULT_CLIENT_TIMEOUT = 0;
7171
public static final int DEFAULT_MAX_FRAME_LENGTH = Integer.MAX_VALUE;
7272

0 commit comments

Comments
 (0)