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

Avoid errors

Browse Source
This commit is contained in:
Andrea Cavalli 2021-08-04 00:44:06 +02:00
parent 2f3cea9d5b
commit bcd99f4727
2 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -280,7 +280,9 @@ public class LLLocalLuceneIndex implements LLLuceneIndex {
@Override @Override
public void run() { public void run() {
scheduledTasksLifecycle.startScheduledTask(); if (!scheduledTasksLifecycle.tryStartScheduledTask()) {
return;
}
try { try {
if (scheduledTasksLifecycle.isCancelled() || cancelled) return; if (scheduledTasksLifecycle.isCancelled() || cancelled) return;
task.run(); task.run();

13
src/main/java/it/cavallium/dbengine/lucene/ScheduledTaskLifecycle.java
View File

@ -27,6 +27,19 @@ public class ScheduledTaskLifecycle {
this.lock.readLock(); this.lock.readLock();
} }
/**
* Mark this task as running.
* After calling this method, please call {@method endScheduledTask} inside a finally block!
* @return false if failed
*/
public boolean tryStartScheduledTask() {
if (cancelled) {
return false;
}
this.lock.readLock();
return true;
}
/** /**
* Mark this task as ended. Must be called after {@method startScheduledTask} * Mark this task as ended. Must be called after {@method startScheduledTask}
*/ */