stepus53/dhfs
1
0
Fork 0
mirror of https://github.com/usatiuk/dhfs.git synced 2025-10-29 04:57:48 +01:00
Code Issues Packages Projects Releases Wiki Activity

Server: tx thread count depends on cpu

Browse Source
This commit is contained in:
Stepan Usatiuk
2024-10-12 14:04:14 +02:00
parent d43a76da3e
commit 8dc16e672a
3 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
dhfs-parent/server/src/main/java/com/usatiuk/dhfs/objects/jrepository/JObjectTxManager.java
View File

@@ -48,8 +48,7 @@ public class JObjectTxManager {
.namingPattern("tx-serializer-%d")
.build();
// FIXME:
_serializerThreads = Executors.newFixedThreadPool(16, factory);
_serializerThreads = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors(), factory);
}
public void begin() {

2
dhfs-parent/server/src/main/java/com/usatiuk/dhfs/objects/jrepository/TxWritebackImpl.java
View File

@@ -58,7 +58,7 @@ public class TxWritebackImpl implements TxWriteback {
.namingPattern("writeback-commit-%d")
.build();
_commitExecutor = Executors.newFixedThreadPool(8, factory);
_commitExecutor = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors(), factory);
}
_statusExecutor = Executors.newSingleThreadExecutor();
_statusExecutor.submit(() -> {

2
dhfs-parent/server/src/main/java/com/usatiuk/dhfs/objects/repository/persistence/FileObjectPersistentStore.java
View File

@@ -80,7 +80,7 @@ public class FileObjectPersistentStore implements ObjectPersistentStore {
.namingPattern("persistent-commit-%d")
.build();
_flushExecutor = Executors.newFixedThreadPool(8, factory);
_flushExecutor = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors(), factory);
}
tryReplay();