Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 228 for ShutDown (0.09 sec)

  1. build-logic/cleanup/src/main/kotlin/gradlebuild/cleanup/services/DaemonTracker.kt

            forEachJavaProcess { pid, _ ->
                suspiciousDaemons.forEach { (suite, pids) ->
                    if (pid in pids && pid !in alreadyKilled) {
                        logger.warn("A process was created in $suite but wasn't shutdown properly. Killing PID $pid")
                        KillLeakingJavaProcesses.pkill(pid)
                    }
                }
            }
        }
    
        private
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Mon Jan 08 12:45:57 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java

                            throw new AssertionError();
                        }
                      }
                      return threadSum;
                    }
                  }));
        }
        threadPool.shutdown();
        assertTrue(threadPool.awaitTermination(300, SECONDS));
        long sum = 0;
        for (Future<Long> f : futures) {
          sum += f.get();
        }
        assertEquals(sum, map.get(key));
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 13 14:28:25 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt

     * ```
     *
     * ## Shutdown Isn't Necessary
     *
     * The threads and connections that are held will be released automatically if they remain idle. But
     * if you are writing a application that needs to aggressively release unused resources you may do
     * so.
     *
     * Shutdown the dispatcher's executor service with [shutdown()][ExecutorService.shutdown]. This will
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:21:33 UTC 2024
    - 52K bytes
    - Viewed (0)
  4. android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java

        ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor();
        assertFalse(executor.isShutdown());
        assertFalse(executor.isTerminated());
        executor.shutdown();
        assertTrue(executor.isShutdown());
        assertTrue(executor.isTerminated());
      }
    
      public void testNoOpScheduledExecutorInvokeAll() throws ExecutionException, InterruptedException {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractListeningExecutorService.java

     * with the abstract {@link #execute execute(Runnable)} method.
     *
     * <p>In addition to {@link #execute}, subclasses must implement all methods related to shutdown and
     * termination.
     *
     * @author Chris Povirk
     * @since 14.0
     */
    @CheckReturnValue
    @GwtIncompatible
    @J2ktIncompatible
    @ElementTypesAreNonnullByDefault
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 3K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/AbstractListeningExecutorService.java

     * with the abstract {@link #execute execute(Runnable)} method.
     *
     * <p>In addition to {@link #execute}, subclasses must implement all methods related to shutdown and
     * termination.
     *
     * @author Chris Povirk
     * @since 14.0
     */
    @CheckReturnValue
    @GwtIncompatible
    @J2ktIncompatible
    @ElementTypesAreNonnullByDefault
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 3K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

                listenerLatch.countDown();
              }
            },
            directExecutor());
      }
    
      @Override
      protected void tearDown() throws Exception {
        if (exec != null) {
          exec.shutdown();
        }
    
        super.tearDown();
      }
    
      public void testListenerDoesNotRunUntilTaskCompletes() throws Exception {
    
        // Test default state of not started.
        assertEquals(1, listenerLatch.getCount());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  8. src/main/java/jcifs/context/AbstractCIFSContext.java

        @Override
        public void run () {
            try {
                this.closed = true;
                close();
            }
            catch ( CIFSException e ) {
                log.warn("Failed to close context on shutdown", e);
            }
        }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Tue Jul 07 10:50:16 UTC 2020
    - 3.7K bytes
    - Viewed (0)
  9. regression-test/src/androidTest/java/okhttp/regression/compare/AndroidHttpEngineTest.kt

              .build(),
          )
          .addQuicHint("google.com", 443, 443)
          .addQuicHint("www.google.com", 443, 443)
          .build()
    
      @After
      fun tearDown() {
        engine.shutdown()
        cacheDir.deleteRecursively()
      }
    
      @Test
      fun get() {
        val executor = Executors.newCachedThreadPool()
    
        val completableFuture = execute(engine, executor, "https://google.com/robots.txt")
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 24 13:19:43 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/AutobahnTester.kt

          println("Test count: $count")
          for (number in 1..count) {
            runTest(number, count)
          }
          updateReports()
        } finally {
          client.dispatcher.executorService.shutdown()
        }
      }
    
      private fun runTest(
        number: Long,
        count: Long,
      ) {
        val latch = CountDownLatch(1)
        val startNanos = AtomicLong()
        newWebSocket(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.6K bytes
    - Viewed (0)
Back to top