Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for addShutdownHook (0.1 sec)

  1. compat/maven-compat/src/test/java/org/apache/maven/artifact/testutils/TestFileManager.java

            callerInfo = new NullPointerException().getStackTrace()[2];
    
            Runnable warning = this::maybeWarnAboutCleanUp;
    
            cleanupWarning = new Thread(warning);
    
            Runtime.getRuntime().addShutdownHook(cleanupWarning);
        }
    
        private void maybeWarnAboutCleanUp() {
            if (warnAboutCleanup) {
                System.out.println("[WARNING] TestFileManager from: " + callerInfo.getClassName() + " not cleaned up!");
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/MoreExecutors.java

                        // We're shutting down anyway, so just ignore.
                      }
                    }
                  }));
        }
    
        @VisibleForTesting
        void addShutdownHook(Thread hook) {
          Runtime.getRuntime().addShutdownHook(hook);
        }
      }
    
      @J2ktIncompatible
      @GwtIncompatible // TODO
      private static void useDaemonThreadFactory(ThreadPoolExecutor executor) {
        executor.setThreadFactory(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

            .testNulls();
      }
    
      private static class TestApplication extends Application {
        private final List<Thread> hooks = Lists.newArrayList();
    
        @Override
        synchronized void addShutdownHook(Thread hook) {
          hooks.add(hook);
        }
    
        synchronized void shutdown() throws InterruptedException {
          for (Thread hook : hooks) {
            hook.start();
          }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/exec/Crawler.java

                    @Override
                    public void run() {
                        destroyContainer();
                    }
    
                };
                Runtime.getRuntime().addShutdownHook(shutdownCallback);
    
                commandThread = new Thread(() -> {
                    try (BufferedReader reader = new BufferedReader(new InputStreamReader(System.in))) {
                        String command;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 24K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

            .testNulls();
      }
    
      private static class TestApplication extends Application {
        private final List<Thread> hooks = Lists.newArrayList();
    
        @Override
        synchronized void addShutdownHook(Thread hook) {
          hooks.add(hook);
        }
    
        synchronized void shutdown() throws InterruptedException {
          for (Thread hook : hooks) {
            hook.start();
          }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/helper/SystemHelper.java

                defaultMap.put(Constants.ITEM_VALUE, "all");
                langItems.add(defaultMap);
                return langItems;
            }
        }
    
        public void addShutdownHook(final Runnable hook) {
            shutdownHookList.add(hook);
        }
    
        public String getHostname() {
            final Map<String, String> env = getEnvMap();
            if (env.containsKey("COMPUTERNAME")) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Oct 17 12:10:08 UTC 2024
    - 27.2K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

     *           // some other action.  For now we will just exit.
     *           System.exit(1);
     *         }
     *       },
     *       MoreExecutors.directExecutor());
     *
     *     Runtime.getRuntime().addShutdownHook(new Thread() {
     *       public void run() {
     *         // Give the services 5 seconds to stop to ensure that we are responsive to shutdown
     *         // requests.
     *         try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.5K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/ServiceManager.java

     *           // some other action.  For now we will just exit.
     *           System.exit(1);
     *         }
     *       },
     *       MoreExecutors.directExecutor());
     *
     *     Runtime.getRuntime().addShutdownHook(new Thread() {
     *       public void run() {
     *         // Give the services 5 seconds to stop to ensure that we are responsive to shutdown
     *         // requests.
     *         try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.2K bytes
    - Viewed (0)
Back to top