- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 198 for isShutdown (3.93 sec)
-
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/api/HandleStop.java
} } private void hangShutdownForTesting() { // For testing purposes, if this system property is set, the daemon will wait the specified // number of milliseconds before continuing to shutdown. This simulates builds for daemons // that are very slow to respond. int hang = Integer.getInteger("org.gradle.internal.testing.daemon.hang", 0); if (hang > 0) { try {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2.7K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/main/kotlin/org/gradle/kotlin/dsl/concurrent/BuildServices.kt
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 3.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListenableFutureTester.java
} }, exec); assertEquals(1, latch.getCount()); assertFalse(future.isDone()); assertFalse(future.isCancelled()); } public void tearDown() { exec.shutdown(); } public void testCompletedFuture(@Nullable Object expectedValue) throws InterruptedException, ExecutionException { assertTrue(future.isDone()); assertFalse(future.isCancelled());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 3.3K bytes - Viewed (0) -
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: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 4.2K bytes - Viewed (0) -
build-logic/cleanup/src/main/kotlin/gradlebuild/cleanup/services/DaemonTracker.kt
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jan 08 12:45:57 UTC 2024 - 3.4K bytes - Viewed (0) -
platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/AbstractManagedExecutor.java
} finally { executing.remove(); } } }; } @Override public void requestStop() { delegate.shutdown(); } @Override public void stop() { stop(Integer.MAX_VALUE, TimeUnit.SECONDS); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 3.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTester.java
} }, exec); assertEquals(1, latch.getCount()); assertFalse(future.isDone()); assertFalse(future.isCancelled()); } public void tearDown() { exec.shutdown(); } public void testCompletedFuture(@Nullable Object expectedValue) throws InterruptedException, ExecutionException { assertTrue(future.isDone()); assertFalse(future.isCancelled());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 3.3K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/test/kotlin/org/gradle/internal/cc/impl/InputTrackingStateTest.kt
val enabledOnOtherThread: Boolean try { enabledOnOtherThread = otherThread.submit(state::isEnabledForCurrentThread).get() } finally { otherThread.shutdown() } assertTrue(enabledOnOtherThread) } @Test fun `input tracking is restored to the state when it was disabled`() { val state = InputTrackingState()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 3.7K bytes - Viewed (0) -
cmd/kube-controller-manager/app/options/attachdetachcontroller.go
fs.BoolVar(&o.DisableForceDetachOnTimeout, "disable-force-detach-on-timeout", false, "Prevent force detaching volumes based on maximum unmount time and node status. If this flag is set to true, the non-graceful node shutdown feature must be used to recover from node failure. See https://k8s.io/docs/storage-disable-force-detach-on-timeout/.") } // ApplyTo fills up AttachDetachController config with options.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 22 18:31:52 UTC 2024 - 2.8K bytes - Viewed (0) -
android/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: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 4.2K bytes - Viewed (0)