feat(batch): do not interrupt the parent thread if the context is being closed already

Author: bevzzz

src/main/java/io/weaviate/client6/v1/api/collections/batch/BatchContext.java

@@ -294,7 +294,7 @@ private void shutdown() {
   }
 
   private void shutdownNow(Exception ex) {
-    // Now report this error to the server and close the stream.
+    // Now report this error to the server and terminate the stream.
     closing.completeExceptionally(ex);
     messages.onError(Status.INTERNAL.withCause(ex).asRuntimeException());
 
@@ -307,10 +307,12 @@ private void shutdownNow(Exception ex) {
     } catch (Exception e) {
     }
 
-    // Since shutdownNow is never triggered by the "main" thread,
-    // it may be blocked on trying to add to the queue. While batch
-    // context is active, we own this thread and may interrupt it.
-    parent.interrupt();
+    if (!closed) {
+      // Since shutdownNow is never triggered by the "main" thread,
+      // it may be blocked on trying to add to the queue. While batch
+      // context is active, we own this thread and may interrupt it.
+      parent.interrupt();
+    }
   }
 
   private void shutdownExecutors() {