Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 51 - 54 of 54 for shutdownNow (0.07 seconds)

  1. src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java

            } catch (final InterruptedException e) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Executor shutdown interrupted", e);
                }
            } finally {
                executor.shutdownNow();
            }
    
            synchronized (indexUpdateCallback) {
                if (!deleteUrlList.isEmpty()) {
                    deleteDocuments();
                }
            }
            indexUpdateCallback.commit();
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 29.7K bytes
    - Click Count (3)
  2. src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java

                    if (logger.isDebugEnabled()) {
                        logger.debug("Executor shutdown interrupted", e);
                    }
                } finally {
                    executorService.shutdownNow();
                }
            }
        }
    
        /**
         * Performs a search operation using rank fusion across available searchers.
         * If only one searcher is available, uses the main searcher. Otherwise, performs
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Dec 25 02:13:14 GMT 2025
    - 28K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

          propagateIfInstanceOf(e.getCause(), CancellationException.class);
          throw new AssertionError("Unexpected exception", e);
        } finally {
          executor.shutdownNow();
          // TODO(cpovirk): assertTrue(awaitTerminationUninterruptibly(executor, 10, SECONDS));
        }
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

          propagateIfInstanceOf(e.getCause(), CancellationException.class);
          throw new AssertionError("Unexpected exception", e);
        } finally {
          executor.shutdownNow();
          // TODO(cpovirk): assertTrue(awaitTerminationUninterruptibly(executor, 10, SECONDS));
        }
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
Back to Top