From cc998f1de4651f63b7cf480f3b2477ffead3525d Mon Sep 17 00:00:00 2001
From: Andrea Cavalli <andrea@cavallium.it>
Date: Mon, 16 Sep 2024 13:31:41 +0200
Subject: [PATCH] Fix parallelization

---
 .../it/cavallium/rockserver/core/client/EmbeddedConnection.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/it/cavallium/rockserver/core/client/EmbeddedConnection.java b/src/main/java/it/cavallium/rockserver/core/client/EmbeddedConnection.java
index 88b6e22..826226b 100644
--- a/src/main/java/it/cavallium/rockserver/core/client/EmbeddedConnection.java
+++ b/src/main/java/it/cavallium/rockserver/core/client/EmbeddedConnection.java
@@ -34,7 +34,7 @@ public class EmbeddedConnection extends BaseConnection implements RocksDBAPI {
 	public EmbeddedConnection(@Nullable Path path, String name, @Nullable Path embeddedConfig) throws IOException {
 		super(name);
 		this.db = new EmbeddedDB(path, name, embeddedConfig);
-		this.exeuctor = Executors.newVirtualThreadPerTaskExecutor();
+		this.exeuctor = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
 	}
 
 	@Override