NanaChiyo0721/Shiroha
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

[ci skip] Check interval -> Scan interval

Browse Source
This commit is contained in:
NanaChiyo0721
2026-08-19 11:37:47 +08:00
parent 899927a935
commit 87451df0c0
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
shiroha-server/src/main/java/io/nanachiyo0721/shiroha/data/BufferedLinearRegionFileFlusher.java
+3 -3
View File
@@ -20,9 +20,9 @@ public class BufferedLinearRegionFileFlusher implements Runnable {
private final Executor ioWorkerPool; private final Executor ioWorkerPool;
private final long flushOfWriteTimeoutMs; private final long flushOfWriteTimeoutMs;
public BufferedLinearRegionFileFlusher(int nIoThreads, long checkIntervalMs, long flushOfWriteTimeoutMs) { public BufferedLinearRegionFileFlusher(int nIoThreads, long scanInterval, long flushOfWriteTimeoutMs) {
Validate.isTrue(nIoThreads > 0, "Number of I/O threads must > 0!"); Validate.isTrue(nIoThreads > 0, "Number of I/O threads must > 0!");
Validate.isTrue(checkIntervalMs > 0, "Check interval must > 0"); Validate.isTrue(scanInterval > 0, "Scan interval must > 0");
Validate.isTrue(flushOfWriteTimeoutMs > 0, "Flush of write timeout must > 0"); Validate.isTrue(flushOfWriteTimeoutMs > 0, "Flush of write timeout must > 0");
this.ioWorkerPool = Executors.newFixedThreadPool(nIoThreads, new ThreadFactoryBuilder() this.ioWorkerPool = Executors.newFixedThreadPool(nIoThreads, new ThreadFactoryBuilder()
@@ -34,7 +34,7 @@ public class BufferedLinearRegionFileFlusher implements Runnable {
.setNameFormat("BufferedLinearRegionFile Flusher Checker") .setNameFormat("BufferedLinearRegionFile Flusher Checker")
.setDaemon(true) .setDaemon(true)
.build()) .build())
.scheduleWithFixedDelay(this, checkIntervalMs, checkIntervalMs, TimeUnit.MILLISECONDS); .scheduleWithFixedDelay(this, scanInterval, scanInterval, TimeUnit.MILLISECONDS);
this.flushOfWriteTimeoutMs = flushOfWriteTimeoutMs; this.flushOfWriteTimeoutMs = flushOfWriteTimeoutMs;
} }