Skip to content

Commit b375c66

Browse files
committed
Re-use named thread pool from java-watch.
1 parent 0ae716b commit b375c66

File tree

1 file changed

+2
-14
lines changed

1 file changed

+2
-14
lines changed

src/org/rascalmpl/ideservices/RemoteIDEServices.java

Lines changed: 2 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -26,15 +26,13 @@
2626
*/
2727
package org.rascalmpl.ideservices;
2828

29+
import engineering.swat.watch.DaemonThreadPool;
2930
import java.io.PrintWriter;
3031
import java.net.InetAddress;
3132
import java.net.Socket;
3233
import java.net.URI;
33-
import java.util.concurrent.Executors;
34-
import java.util.concurrent.ThreadFactory;
3534
import java.util.concurrent.TimeUnit;
3635
import java.util.concurrent.TimeoutException;
37-
import java.util.concurrent.atomic.AtomicInteger;
3836
import org.eclipse.lsp4j.jsonrpc.Launcher;
3937
import org.jline.terminal.Terminal;
4038
import org.rascalmpl.debug.IRascalMonitor;
@@ -67,17 +65,7 @@ public RemoteIDEServices(int ideServicesPort, PrintWriter stderr, IRascalMonitor
6765
.setInput(socket.getInputStream())
6866
.setOutput(socket.getOutputStream())
6967
.configureGson(GsonUtils::configureGson)
70-
.setExecutorService(Executors.newCachedThreadPool(new ThreadFactory() {
71-
AtomicInteger counter = new AtomicInteger();
72-
73-
@Override
74-
public Thread newThread(Runnable r) {
75-
Thread t = new Thread("rascal-ide-services-" + counter.incrementAndGet());
76-
t.setDaemon(true);
77-
return t;
78-
}
79-
80-
}))
68+
.setExecutorService(DaemonThreadPool.buildConstrainedCached("rascal-ide-services", Runtime.getRuntime().availableProcessors()))
8169
.create();
8270

8371
clientLauncher.startListening();

0 commit comments

Comments
 (0)