fix: fixed larger closing time of the database introduced after 23.5.1

Fixed issue #1234
ArcadeData · Sep 10, 2023 · 0d29ef0 · 0d29ef0
1 parent ce15b04
commit 0d29ef0
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/engine/src/main/java/com/arcadedb/engine/PageManager.java b/engine/src/main/java/com/arcadedb/engine/PageManager.java
@@ -100,6 +100,7 @@ public void close() {
     if (flushThread != null) {
       try {
         flushThread.close();
+        flushThread.interrupt();
         flushThread.join();
       } catch (final InterruptedException e) {
         Thread.currentThread().interrupt();
@@ -132,6 +133,7 @@ public void kill() {
     if (flushThread != null) {
       try {
         flushThread.close();
+        flushThread.interrupt();
         flushThread.join();
       } catch (final InterruptedException e) {
         Thread.currentThread().interrupt();

diff --git a/engine/src/main/java/com/arcadedb/engine/PageManagerFlushThread.java b/engine/src/main/java/com/arcadedb/engine/PageManagerFlushThread.java
@@ -73,9 +73,7 @@ public void run() {
         flushPagesFromQueueToDisk();
 
       } catch (final InterruptedException e) {
-        Thread.currentThread().interrupt();
         running = false;
-        return;
       } catch (final Exception e) {
         LogManager.instance().log(this, Level.SEVERE, "Error on processing page flush requests", e);
       }