Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 218 for ShutDown (0.15 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. okhttp/src/test/java/okhttp3/SocksProxyTest.kt

      private val socksProxy = SocksProxy()
    
      @BeforeEach
      fun setUp(server: MockWebServer) {
        this.server = server
        socksProxy.play()
      }
    
      @AfterEach
      fun tearDown() {
        socksProxy.shutdown()
      }
    
      @Test
      fun proxy() {
        server.enqueue(MockResponse.Builder().body("abc").build())
        server.enqueue(MockResponse.Builder().body("def").build())
        val client =
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  8. 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)
  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. samples/crawler/src/main/java/okhttp3/sample/Crawler.java

          executor.execute(() -> {
            try {
              drainQueue();
            } catch (Exception e) {
              e.printStackTrace();
            }
          });
        }
        executor.shutdown();
      }
    
      private void drainQueue() throws Exception {
        for (HttpUrl url; (url = queue.take()) != null; ) {
          if (!fetchedUrls.add(url)) {
            continue;
          }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Aug 12 07:26:27 UTC 2021
    - 4.6K bytes
    - Viewed (0)
Back to top