- Sort Score
- Num 10 results
- Language All
Results 61 - 70 of 785 for Threads (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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) -
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) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/BuildThreadFactory.java
/** * Simple {@link ThreadFactory} implementation that ensures the corresponding threads have a meaningful name. */ public class BuildThreadFactory implements ThreadFactory { private final AtomicInteger id = new AtomicInteger(); private static final String PREFIX = "BuilderThread"; @Override public Thread newThread(Runnable r) { return new Thread(r, String.format("%s-%d", PREFIX, id.getAndIncrement())); }Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 1.4K bytes - Click Count (0) -
android/guava/src/com/google/common/eventbus/AllowConcurrentEvents.java
import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; /** * Marks an event subscriber method as being thread-safe. This annotation indicates that EventBus * may invoke the event subscriber simultaneously from multiple threads. * * <p>This does not mark the method, and so should be used in combination with {@link Subscribe}. * * @author Cliff Biffle * @since 10.0 */Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 1.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) -
android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jul 17 15:26:41 GMT 2025 - 7.5K bytes - Click Count (0) -
guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
* * <p>This class supports an optional fairness policy for ordering waiting producer and consumer * threads. By default, this ordering is not guaranteed. However, a queue constructed with fairness * set to {@code true} grants threads access in FIFO order. Fairness generally decreases throughput * but reduces variability and avoids starvation. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 21:06:42 GMT 2026 - 22.4K bytes - Click Count (0) -
guava-tests/benchmark/com/google/common/collect/ConcurrentHashMultisetBenchmark.java
}); } private long doMultithreadedLoop(Callable<Long> task) throws InterruptedException, ExecutionException { List<Future<Long>> futures = Lists.newArrayListWithCapacity(threads); for (int i = 0; i < threads; i++) { futures.add(threadPool.submit(task)); } long total = 0; for (Future<Long> future : futures) { total += future.get(); } return total; }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Jul 14 14:44:08 GMT 2025 - 16.6K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackImplTest.java
// Test thread safety final int threadCount = 10; final int docsPerThread = 10; final List<Thread> threads = new ArrayList<>(); final AtomicInteger successCount = new AtomicInteger(0); for (int i = 0; i < threadCount; i++) { final int threadId = i; Thread thread = new Thread(() -> {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 24.7K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/HashBasedTable.java
* since an iteration across all row keys occurs. * * <p>Note that this implementation is not synchronized. If multiple threads access this table * concurrently and one of the threads modifies the table, it must be synchronized externally. * * <p>See the Guava User Guide article on <a href=
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 13:11:08 GMT 2026 - 4.1K bytes - Click Count (0)