- Sort Score
- Num 10 results
- Language All
Results 71 - 80 of 973 for Threads (0.04 seconds)
-
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvn/LayeredMavenOptions.java
public Optional<Boolean> alsoMakeDependents() { return returnFirstPresentOrEmpty(MavenOptions::alsoMakeDependents); } @Override public Optional<String> threads() { return returnFirstPresentOrEmpty(MavenOptions::threads); } @Override public Optional<String> builder() { return returnFirstPresentOrEmpty(MavenOptions::builder); } @Override
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Wed Jun 11 13:14:09 GMT 2025 - 5.4K bytes - Click Count (0) -
api/maven-api-cli/src/main/java/org/apache/maven/api/cli/mvn/MavenOptions.java
@Nonnull Optional<Boolean> alsoMakeDependents(); /** * Returns the number of threads used for parallel builds. * * @return an {@link Optional} containing the number of threads (or "1C" for one thread per CPU core), or empty if not specified */ @Nonnull Optional<String> threads(); /** * Returns the id of the build strategy to use. *Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Wed Jun 11 13:14:09 GMT 2025 - 8K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
/** Returns a new started daemon Thread running the given runnable. */ final Thread newStartedThread(Runnable runnable) { Thread t = new Thread(runnable); t.setDaemon(true); t.start(); return t; } /** * Waits for the specified time (in milliseconds) for the thread to terminate (using {@link * Thread#join(long)}), else interrupts the thread (in the hope that it may terminate later) and
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 8.8K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
} @J2ktIncompatible @GwtIncompatible // threads public void testSubmitAsync_asyncCallable_returnsInterruptedFuture() throws InterruptedException { assertThat(Thread.interrupted()).isFalse(); SettableFuture<Integer> cancelledFuture = SettableFuture.create(); cancelledFuture.cancel(true); assertThat(Thread.interrupted()).isFalse();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 134K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
} @J2ktIncompatible @GwtIncompatible // threads public void testSubmitAsync_asyncCallable_returnsInterruptedFuture() throws InterruptedException { assertThat(Thread.interrupted()).isFalse(); SettableFuture<Integer> cancelledFuture = SettableFuture.create(); cancelledFuture.cancel(true); assertThat(Thread.interrupted()).isFalse();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 134K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvn/CommonsCliMavenOptions.java
return Optional.of(Boolean.TRUE); } return Optional.empty(); } @Override public Optional<String> threads() { if (commandLine.hasOption(CLIManager.THREADS)) { return Optional.of(commandLine.getOptionValue(CLIManager.THREADS)); } return Optional.empty(); } @Override public Optional<String> builder() {
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Thu Sep 25 17:39:57 GMT 2025 - 14.8K bytes - Click Count (0) -
guava/src/com/google/common/cache/LoadingCache.java
* instances is using {@link CacheBuilder}. * * <p>Implementations of this interface are expected to be thread-safe, and can be safely accessed * by multiple concurrent threads. * * <p>When evaluated as a {@link Function}, a cache yields the same result as invoking {@link * #getUnchecked}. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 03 12:40:22 GMT 2026 - 8.5K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Monitor.java
*/ public boolean hasQueuedThread(Thread thread) { return lock.hasQueuedThread(thread); } /** * Queries whether any threads are waiting for the given guard to become satisfied. Note that * because timeouts and interrupts may occur at any time, a {@code true} return does not guarantee * that the guard becoming satisfied in the future will awaken any threads. This method is
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jan 28 22:39:02 GMT 2026 - 43.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
return; } TimedWaiterThread thread = new TimedWaiterThread(new AbstractFuture<Object>() {}, 2, SECONDS); thread.start(); thread.awaitWaiting(); Thread.class.getMethod("suspend").invoke(thread); // Sleep for enough time to add 1500 milliseconds of overwait to the get() call. long toWaitMillis = 3500 - NANOSECONDS.toMillis(System.nanoTime() - thread.startTime); Thread.sleep(toWaitMillis);Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 45.2K bytes - Click Count (0) -
src/test/java/jcifs/smb/PreauthIntegrityTest.java
fail("Thread failed: " + e.getMessage()); } finally { doneLatch.countDown(); } }); } // Start all threads at once startLatch.countDown(); // Wait for completion assertTrue(doneLatch.await(5, TimeUnit.SECONDS), "Threads did not complete in time"); executor.shutdown();
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 10.5K bytes - Click Count (0)