Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 73 for isShutdown (0.07 sec)

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

        assertFalse(testExecutor.isTerminated());
        mock.assertLastMethodCalled("isTerminated");
        assertFalse(testExecutor.isShutdown());
        mock.assertLastMethodCalled("isShutdown");
        testExecutor.shutdown();
        mock.assertLastMethodCalled("shutdown");
        List<Runnable> list = testExecutor.shutdownNow();
        mock.assertLastMethodCalled("shutdownNow");
        assertEquals(ImmutableList.of(), list);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        ExecutorService service = mock(ExecutorService.class);
        application.addDelayedShutdownHook(service, 2, SECONDS);
        verify(service, Mockito.never()).shutdown();
        application.shutdown();
        InOrder shutdownFirst = Mockito.inOrder(service);
        shutdownFirst.verify(service).shutdown();
        shutdownFirst.verify(service).awaitTermination(2, SECONDS);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

        assertFalse(testExecutor.isTerminated());
        mock.assertLastMethodCalled("isTerminated");
        assertFalse(testExecutor.isShutdown());
        mock.assertLastMethodCalled("isShutdown");
        testExecutor.shutdown();
        mock.assertLastMethodCalled("shutdown");
        List<Runnable> list = testExecutor.shutdownNow();
        mock.assertLastMethodCalled("shutdownNow");
        assertEquals(ImmutableList.of(), list);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        ExecutorService service = mock(ExecutorService.class);
        application.addDelayedShutdownHook(service, 2, SECONDS);
        verify(service, Mockito.never()).shutdown();
        application.shutdown();
        InOrder shutdownFirst = Mockito.inOrder(service);
        shutdownFirst.verify(service).shutdown();
        shutdownFirst.verify(service).awaitTermination(2, SECONDS);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

       */
      @Throws(IOException::class)
      fun shutdown(statusCode: ErrorCode) {
        writer.withLock {
          val lastGoodStreamId: Int
          this.withLock {
            if (isShutdown) {
              return
            }
            isShutdown = true
            lastGoodStreamId = this.lastGoodStreamId
          }
          // TODO: propagate exception message into debugData.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/MoreExecutors.java

        }
    
        @Override
        public final boolean isShutdown() {
          return delegate.isShutdown();
        }
    
        @Override
        public final boolean isTerminated() {
          return delegate.isTerminated();
        }
    
        @Override
        public final void shutdown() {
          delegate.shutdown();
        }
    
        @Override
        public final List<Runnable> shutdownNow() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

     * the "running" state need to perform a periodic task. Subclasses can implement {@link #startUp},
     * {@link #shutDown} and also a {@link #runOneIteration} method that will be executed periodically.
     *
     * <p>This class uses the {@link ScheduledExecutorService} returned from {@link #executor} to run
     * the {@link #startUp} and {@link #shutDown} methods and also uses that service to schedule the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/FastFallbackTest.kt

            .build()
        url =
          serverIpv4.url("/")
            .newBuilder()
            .host("localhost")
            .build()
      }
    
      @AfterEach
      internal fun tearDown() {
        serverIpv4.shutdown()
        serverIpv6.shutdown()
      }
    
      @Test
      fun callIpv6FirstEvenWhenIpv4IpIsListedFirst() {
        dnsResults =
          listOf(
            localhostIpv4,
            localhostIpv6,
          )
        serverIpv4.enqueue(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  9. src/test/java/jcifs/tests/ConcurrencyTest.java

                    while ( !this.started ) {
                        this.startedLock.wait();
                    }
                }
            }
    
    
            public void shutdown () {
                this.shutdown = true;
                synchronized ( this.shutdownLock ) {
                    this.shutdownLock.notify();
                }
            }
    
    
            /**
             * {@inheritDoc}
             *
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 14 17:40:50 UTC 2021
    - 17.6K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

          enterRun.countDown();
          try {
            exitRun.await();
          } catch (InterruptedException e) {
            throw new RuntimeException(e);
          }
        }
    
        @Override
        protected void shutDown() {
          assertTrue(startUpCalled);
          assertTrue(runCalled);
          assertFalse(shutDownCalled);
          shutDownCalled = true;
          assertEquals(expectedShutdownState, state());
        }
    
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 12.7K bytes
    - Viewed (0)
Back to top