Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 20 for IsTerminated (0.33 sec)

  1. testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/TestManagedExecutor.groovy

        }
    
        List<Runnable> shutdownNow() {
            throw new UnsupportedOperationException()
        }
    
        boolean isShutdown() {
            throw new UnsupportedOperationException()
        }
    
        boolean isTerminated() {
            throw new UnsupportedOperationException()
        }
    
        boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
            throw new UnsupportedOperationException()
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

        assertFalse(executor.isTerminated());
        assertInterrupted();
      }
    
      public void testTryAwaitTerminationInfiniteTimeout() {
        ExecutorService executor = newFixedThreadPool(1);
        requestInterruptIn(500);
        executor.execute(new SleepTask(1000));
        executor.shutdown();
        awaitTerminationUninterruptibly(executor);
        assertTrue(executor.isTerminated());
        assertInterrupted();
      }
    
      /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Jun 10 16:06:39 UTC 2024
    - 31.7K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/DirectExecutorService.java

      @Override
      public List<Runnable> shutdownNow() {
        shutdown();
        return Collections.emptyList();
      }
    
      @Override
      public boolean isTerminated() {
        synchronized (lock) {
          return shutdown && runningTasks == 0;
        }
      }
    
      @Override
      public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 15 10:40:05 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  4. guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

          shutdown();
          return ImmutableList.of();
        }
    
        @Override
        public boolean isShutdown() {
          return shutdown;
        }
    
        @Override
        public boolean isTerminated() {
          return shutdown;
        }
    
        @Override
        public boolean awaitTermination(long timeout, TimeUnit unit) {
          return true;
        }
    
        @Override
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri May 17 17:12:37 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  5. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

          shutdown();
          return ImmutableList.of();
        }
    
        @Override
        public boolean isShutdown() {
          return shutdown;
        }
    
        @Override
        public boolean isTerminated() {
          return shutdown;
        }
    
        @Override
        public boolean awaitTermination(long timeout, TimeUnit unit) {
          return true;
        }
    
        @Override
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri May 17 17:12:37 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  6. pkg/kubelet/pod_workers.go

    	if status, ok := p.podSyncStatuses[uid]; ok {
    		return status.IsTerminated()
    	}
    	// if the pod is not known, we return false (pod worker is not aware of it)
    	return false
    }
    
    func (p *podWorkers) CouldHaveRunningContainers(uid types.UID) bool {
    	p.podLock.Lock()
    	defer p.podLock.Unlock()
    	if status, ok := p.podSyncStatuses[uid]; ok {
    		return !status.IsTerminated()
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 02 13:22:37 UTC 2024
    - 74.8K bytes
    - Viewed (0)
  7. 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: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 15 10:40:05 UTC 2024
    - 43.7K bytes
    - Viewed (0)
  8. android/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: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 15 10:40:05 UTC 2024
    - 39K bytes
    - Viewed (0)
  9. subprojects/core/src/testFixtures/groovy/org/gradle/util/internal/MultithreadedTestRule.java

            }
    
            @Override
            public boolean isShutdown() {
                throw new UnsupportedOperationException();
            }
    
            @Override
            public boolean isTerminated() {
                throw new UnsupportedOperationException();
            }
        }
    
        public interface ThreadHandle {
            ThreadHandle waitFor();
    
            boolean waitUntil(Date expiry);
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Oct 05 19:36:14 UTC 2023
    - 23.3K bytes
    - Viewed (0)
  10. testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/ConcurrentTestUtil.groovy

        List<Runnable> shutdownNow() {
            throw new UnsupportedOperationException()
        }
    
        boolean isShutdown() {
            throw new UnsupportedOperationException()
        }
    
        boolean isTerminated() {
            throw new UnsupportedOperationException()
        }
    
        boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
            throw new UnsupportedOperationException()
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 22.9K bytes
    - Viewed (0)
Back to top