stef_buwalda/pism
1
0
Fork 0
mirror of https://github.com/2OOP/pism.git synced 2026-02-04 10:54:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

Moved async runner to virtual thread

Browse Source
This commit is contained in:
Bas de Jong
2026-01-12 16:15:55 +01:00
parent 848d257b9c
commit d2e1edab5c
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
framework/src/main/java/org/toop/framework/networking/server/tournaments/AsyncTournamentRunner.java
View File

@@ -22,10 +22,8 @@ public class AsyncTournamentRunner implements TournamentRunner {
String gameType String gameType
) { ) {
ExecutorService matchExecutor = ExecutorService matchExecutor = Executors.newVirtualThreadPerTaskExecutor();
Executors.newFixedThreadPool( ExecutorService scoringExecutor = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
Runtime.getRuntime().availableProcessors()
);
Queue<TournamentMatch> pendingMatches = new ConcurrentLinkedQueue<>(); Queue<TournamentMatch> pendingMatches = new ConcurrentLinkedQueue<>();
matchMaker.forEach(pendingMatches::add); matchMaker.forEach(pendingMatches::add);
@@ -56,7 +54,11 @@ public class AsyncTournamentRunner implements TournamentRunner {
CompletableFuture.runAsync(() -> { CompletableFuture.runAsync(() -> {
try { try {
GameResultFuture game = matchRunner.submit(gameType, turnTime, a, b); GameResultFuture game = matchRunner.submit(gameType, turnTime, a, b);
scoreSystems.forEach(s -> s.result(match, game.result().join()));
CompletableFuture.runAsync(
() -> scoreSystems.forEach(s -> s.result(match, game.result().join())),
scoringExecutor
).join();
} finally { } finally {
a.clearGame(); a.clearGame();
b.clearGame(); b.clearGame();