andreacavalli/rockserver
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix parallelization

Browse Source
This commit is contained in:
Andrea Cavalli 2024-09-16 13:31:41 +02:00
parent 86a984c1d6
commit cc998f1de4
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/it/cavallium/rockserver/core/client/EmbeddedConnection.java
View File

@ -34,7 +34,7 @@ public class EmbeddedConnection extends BaseConnection implements RocksDBAPI {
public EmbeddedConnection(@Nullable Path path, String name, @Nullable Path embeddedConfig) throws IOException { public EmbeddedConnection(@Nullable Path path, String name, @Nullable Path embeddedConfig) throws IOException {
super(name); super(name);
this.db = new EmbeddedDB(path, name, embeddedConfig); this.db = new EmbeddedDB(path, name, embeddedConfig);
this.exeuctor = Executors.newVirtualThreadPerTaskExecutor(); this.exeuctor = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
} }
@Override @Override