kavin/Piped-Backend
1
0
Fork 0
mirror of https://github.com/TeamPiped/Piped-Backend.git synced 2025-04-29 00:10:31 +05:30
Code Issues Projects Releases Wiki Activity

Use virtual threads.

Browse Source
This commit is contained in:
Kavin 2023-09-20 00:45:07 +01:00
parent b3fd4f2ce9
commit 52229ed8c7
No known key found for this signature in database
GPG Key ID: 6E4598CA5C92C41F
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/me/kavin/piped/Main.java
View File

@ -53,11 +53,11 @@ public class Main {
System.exit(1); System.exit(1);
} }
Multithreading.runAsync(() -> new Thread(new SyncRunner( Multithreading.runAsync(() -> Thread.ofVirtual().start(new SyncRunner(
new OkHttpClient.Builder().readTimeout(60, TimeUnit.SECONDS).build(), new OkHttpClient.Builder().readTimeout(60, TimeUnit.SECONDS).build(),
MATRIX_SERVER, MATRIX_SERVER,
MatrixHelper.MATRIX_TOKEN) MatrixHelper.MATRIX_TOKEN)
).start()); ));
new Timer().scheduleAtFixedRate(new TimerTask() { new Timer().scheduleAtFixedRate(new TimerTask() {
@Override @Override

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

@ -5,7 +5,7 @@ import java.util.function.Supplier;
public class Multithreading { public class Multithreading {
private static final ExecutorService es = Executors.newCachedThreadPool(); private static final ExecutorService es = Executors.newVirtualThreadPerTaskExecutor();
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