Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for isAlive (0.09 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

                interruptingThread.interrupt();
                joinUninterruptibly(interruptingThread, 2500, MILLISECONDS);
                Thread.interrupted();
                if (interruptingThread.isAlive()) {
                  // This will be hidden by test-output redirection:
                  logger.severe("InterruptenatorTask did not exit; future tests may be affected");
                  /*
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  2. src/test/java/org/codelibs/fess/indexer/IndexUpdaterTest.java

            indexUpdater.indexingHelper = indexingHelper;
        }
    
        @Override
        public void tearDown() throws Exception {
            if (indexUpdater != null && indexUpdater.isAlive()) {
                indexUpdater.setFinishCrawling(true);
                indexUpdater.interrupt();
                indexUpdater.join(1000);
            }
            super.tearDown();
        }
    
        // Test initialization
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 33K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

                interruptingThread.interrupt();
                joinUninterruptibly(interruptingThread, 2500, MILLISECONDS);
                Thread.interrupted();
                if (interruptingThread.isAlive()) {
                  // This will be hidden by test-output redirection:
                  logger.severe("InterruptenatorTask did not exit; future tests may be affected");
                  /*
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/exec/Crawler.java

            } catch (final Throwable t) {
                logger.error("Crawler does not work correctly.", t);
                exitCode = Constants.EXIT_FAIL;
            } finally {
                if (commandThread != null && commandThread.isAlive()) {
                    commandThread.interrupt();
                }
                if (systemMonitorTask != null) {
                    systemMonitorTask.cancel();
                }
                if (hotThreadMonitorTask != null) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 31K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

                      () -> {
                        reloadStarted.countDown();
    
                        Thread blockingForRefresh = threadAboutToBlockForRefresh.get();
                        while (blockingForRefresh.isAlive()
                            && blockingForRefresh.getState() != WAITING) {
                          Thread.yield();
                        }
    
                        return key + "Reload";
                      });
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 110.5K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/cache/CacheLoadingTest.java

          thread.start();
          // we want to wait until each thread is WAITING - one thread waiting inside CacheLoader.load
          // (in startSignal.await()), and the others waiting for that thread's result.
          while (thread.isAlive() && thread.getState() != Thread.State.WAITING) {
            Thread.yield();
          }
        }
        gettersStartedSignal.countDown();
        gettersComplete.await();
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 85.7K bytes
    - Viewed (0)
Back to top