andreacavalli/CavalliumDBEngine
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Fix missing scheduling locks

Browse Source
This commit is contained in:
Andrea Cavalli 2020-12-31 12:05:04 +01:00
parent c676fa63a7
commit 84c5fb93a0
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/main/java/it/cavallium/dbengine/database/disk/LLLocalLuceneIndex.java
View File

@ -130,11 +130,14 @@ public class LLLocalLuceneIndex implements LLLuceneIndex {
}
private void registerScheduledFixedTask(Runnable task, Duration duration) {
scheduledTasksLifecycle.registerScheduledTask(scheduler.scheduleAtFixedRate(task,
duration.toMillis(),
duration.toMillis(),
TimeUnit.MILLISECONDS
));
scheduledTasksLifecycle.registerScheduledTask(scheduler.scheduleAtFixedRate(() -> {
scheduledTasksLifecycle.startScheduledTask();
try {
task.run();
} finally {
scheduledTasksLifecycle.endScheduledTask();
}
}, duration.toMillis(), duration.toMillis(), TimeUnit.MILLISECONDS));
}
@Override
@ -401,7 +404,9 @@ public class LLLocalLuceneIndex implements LLLuceneIndex {
private void scheduledQueryRefresh() {
try {
searcherManager.maybeRefreshBlocking();
if (!searcherManager.maybeRefresh()) {
// skipped refreshing because another thread is currently refreshing
}
} catch (IOException ex) {
ex.printStackTrace();
}