From 0d29ef00ac53a079921552b753bffaa5be93c6e7 Mon Sep 17 00:00:00 2001
From: lvca <lvca@users.noreply.github.com>
Date: Sun, 10 Sep 2023 01:51:02 -0400
Subject: [PATCH] fix: fixed larger closing time of the database introduced
 after 23.5.1

Fixed issue #1234
---
 engine/src/main/java/com/arcadedb/engine/PageManager.java       | 2 ++
 .../main/java/com/arcadedb/engine/PageManagerFlushThread.java   | 2 --
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/engine/src/main/java/com/arcadedb/engine/PageManager.java b/engine/src/main/java/com/arcadedb/engine/PageManager.java
index 1987d1b8f..2db80ae98 100644
--- 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
index 9cdbe0b75..f0a138032 100644
--- 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);
       }