mirrors/Piped-Backend
1
0
Fork 0
mirror of https://github.com/TeamPiped/Piped-Backend synced 2025-09-05 21:11:05 +02:00
Code Issues Packages Projects Releases Wiki Activity

Revert to using a regular cached executor.

Browse Source
This commit is contained in:
Kavin 2023-03-18 18:52:04 +00:00
parent a56b13d290
commit 7b2ac41879
No known key found for this signature in database
GPG Key ID: 49451E4482CC5BCD
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/me/kavin/piped/utils/Multithreading.java
View File

@ -1,13 +1,13 @@
package me.kavin.piped.utils; package me.kavin.piped.utils;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.function.Supplier; import java.util.function.Supplier;
public class Multithreading { public class Multithreading {
private static final ExecutorService es = Executors.newVirtualThreadPerTaskExecutor(); private static final ExecutorService es = Executors.newCachedThreadPool();
private static final ExecutorService esLimited = Executors private static final ExecutorService esLimited = Executors
.newFixedThreadPool(Runtime.getRuntime().availableProcessors() * 8); .newFixedThreadPool(Runtime.getRuntime().availableProcessors() * 8);
private static final ExecutorService esLimitedPubSub = Executors private static final ExecutorService esLimitedPubSub = Executors
@ -29,7 +29,7 @@ public class Multithreading {
return es; return es;
} }
public static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier) { public static <U> Future<U> supplyAsync(Supplier<U> supplier) {
return CompletableFuture.supplyAsync(supplier, es); return es.submit(supplier::get);
} }
} }