in.close();
            verify(mockHandle, times(1)).close();
            verify(mockFile, never()).close();
        }

        @Test
        @DisplayName("seToIoe maps Interrupted cause to InterruptedIOException")
        void seToIoeInterruptedMapping() {
            SmbException se = new SmbException("x", new jcifs.util.transport.TransportException(new InterruptedException("boom")));

            throw e;
        } catch (final InterruptedException e) {
            if (mt != null && mt.isTeminated()) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Command execution interrupted due to timeout for user: username={}", username, e);
                }
                throw new CommandExecutionException("The command execution is timeout for user: " + username, e);
            }

                executorService.awaitTermination(60, TimeUnit.SECONDS);
            } catch (final InterruptedException e) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Executor shutdown interrupted", e);
                }
            } finally {
                executorService.shutdownNow();
            }
        }
    }

    /**

                    Thread.sleep(pollInterval);

                } catch (InterruptedException e) {
                    log.debug("Async notification monitoring interrupted for {}", registrationId);
                    Thread.currentThread().interrupt();
                    break;
                } catch (Exception e) {

                if (!task.isExecuted()) {
                    task.run();
                }
            }
        } catch (final InterruptedException e) {
            logger.warn("Interrupted generating thumbnail: id={}, command={}", thumbnailId, cmdList, e);
            Thread.currentThread().interrupt();
        } catch (final Exception e) {

            }).start();
        }

        try {
            latch.await();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            fail("Thread safety test interrupted");
        }

        // In test environment, some operations might not work due to missing request context
        // but the methods should not throw unexpected exceptions
    }

        }

        indexUpdater.setFinishCrawling(true);
        try {
            indexUpdater.join();
        } catch (final InterruptedException e) {
            logger.warn("Interrupted index update.", e);
        }

        crawlingInfoHelper.putToInfoMap(Constants.WEB_FS_INDEX_EXEC_TIME, Long.toString(indexUpdater.getExecuteTime()));

  `Exactly so,' said the Hatter:  `as the things get used up.'

  `But what happens when you come to the beginning again?' Alice
ventured to ask.

  `Suppose we change the subject,' the March Hare interrupted,
yawning.  `I'm getting tired of this.  I vote the young lady
tells us a story.'

  `I'm afraid I don't know one,' said Alice, rather alarmed at
the proposal.

            try {
                latch.await();
            } catch (InterruptedException e) {
                result.addErrorArtifactException(
                        new ArtifactResolutionException("Resolution interrupted", rootArtifact, e));
            }
        }

        // We want to send the root artifact back in the result but we need to do this after the other dependencies
        // have been resolved.

      Path file, Path target, ExecutorService executor) {
    return executor.submit(
        () -> {
          boolean createSymlink = false;
          while (!Thread.interrupted()) {
            try {
              // trying to switch between a real directory and a symlink (dir -> /a)
              if (Files.deleteIfExists(file)) {
                if (createSymlink) {