- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 638 for threadId (0.11 sec)
-
android/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);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 46.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/hash/BloomFilterTest.java
List<Thread> threads = new ArrayList<>(numThreads); List<Throwable> exceptions = new ArrayList<>(numThreads); for (int i = 0; i < numThreads; i++) { Thread thread = new Thread(task); thread.setUncaughtExceptionHandler( new UncaughtExceptionHandler() { @Override public void uncaughtException(Thread t, Throwable e) { exceptions.add(e);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 22K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/UncaughtExceptionHandlers.java
/** * Returns an exception handler that exits the system. This is particularly useful for the main * thread, which may start up other, non-daemon threads, but fail to fully initialize the * application successfully. * * <p>Example usage: * * <pre> * public static void main(String[] args) { * Thread.currentThread().setUncaughtExceptionHandler(UncaughtExceptionHandlers.systemExit()); * ... * </pre> *
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Feb 10 21:03:40 UTC 2025 - 2.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 7.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
@Override public Integer call() { return Thread.currentThread().getStackTrace().length; } }, directExecutor()); settableFuture.set(null); assertThat(getDone(stackDepthCheck)) .isLessThan(Thread.currentThread().getStackTrace().length + 100); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 20:58:01 UTC 2025 - 16.1K bytes - Viewed (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. *
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Wed Jun 11 13:14:09 UTC 2025 - 8K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheLoadingTest.java
} }); thread.start(); // we want to wait until each thread is WAITING - one thread waiting inside CacheLoader.load // (in startSignal.await()), and the others waiting for that thread's result. while (thread.isAlive() && thread.getState() != Thread.State.WAITING) { Thread.yield(); } } gettersStartedSignal.countDown();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 85.7K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
assertFalse(future.isDone()); assertFalse(future.isCancelled()); CountDownLatch successLatch = new CountDownLatch(1); // Run cancellation in a separate thread as an extra thread-safety test. new Thread( () -> { assertThrows(CancellationException.class, future::get); successLatch.countDown(); }) .start();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 6.1K bytes - Viewed (0) -
android/guava/src/com/google/common/base/internal/Finalizer.java
logger.log( Level.INFO, "Failed to create a thread without inherited thread-local values", t); } } if (thread == null) { thread = new Thread((ThreadGroup) null, finalizer, threadName); } thread.setDaemon(true); try { if (inheritableThreadLocals != null) { inheritableThreadLocals.set(thread, null); } } catch (Throwable t) { logger.log(
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 9.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java
return jvmGcObj; }).toArray(n -> new JvmGcObj[n]); final Threads threads = jvmStats.getThreads(); final JvmThreadsObj jvmThreadsObj = new JvmThreadsObj(); jvmObj.threads = jvmThreadsObj; jvmThreadsObj.count = threads.getCount(); jvmThreadsObj.peak = threads.getPeakCount(); final Classes classes = jvmStats.getClasses();
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 19.7K bytes - Viewed (0)