- Sort Score
- Num 10 results
- Language All
Results 161 - 170 of 605 for thead (0.01 seconds)
-
android/guava/src/com/google/common/eventbus/SubscriberRegistry.java
* UncheckedExecutionException, which has the stack trace from this thread and which has its * cause set to the underlying exception (which may be from another thread). If we someday * learn that some other exception besides IllegalArgumentException is common, then we could * add another special case to throw an instance of it, too. */ throw e; }Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Jul 08 18:32:10 GMT 2025 - 10.8K bytes - Click Count (0) -
guava/src/com/google/common/cache/AbstractCache.java
*/ void recordHits(int count); /** * Records cache misses. This should be called when a cache request returns a value that was not * found in the cache. This method should be called by the loading thread, as well as by threads * blocking on the load. Multiple concurrent calls to {@link Cache} lookup methods with the same * key on an absent value should result in a single call to either {@code recordLoadSuccess} orCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 17:27:14 GMT 2025 - 9.1K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java
} public void testFutureCancellableBeforeFunctionCompletion() throws Exception { // Set the result in a separate thread since this test runs the function // (which will block) in the same thread. new Thread() { @Override public void run() { inputFuture.set(SLOW_FUNC_VALID_INPUT_DATA); } }.start(); funcIsWaitingLatch.await();
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 20:07:52 GMT 2025 - 6.4K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java
} public void testFutureCancellableBeforeFunctionCompletion() throws Exception { // Set the result in a separate thread since this test runs the function // (which will block) in the same thread. new Thread() { @Override public void run() { inputFuture.set(SLOW_FUNC_VALID_INPUT_DATA); } }.start(); funcIsWaitingLatch.await();
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 20:07:52 GMT 2025 - 6.4K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/builder/multithreaded/MultiThreadedBuilder.java
* <p> * This builder uses a number of threads equal to the minimum of the degree of concurrency (which is the thread count * set with <code>-T</code> on the command-line) and the number of projects to build. As such, building a single project * will always result in a sequential build, regardless of the thread count. * </p> * <strong>NOTE:</strong> This class is not part of any public api and can be changed or deleted without prior notice.
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Wed Jul 16 03:42:09 GMT 2025 - 8.9K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/PlexusContainerCapsuleFactory.java
Thread.currentThread().setContextClassLoader(containerRealm); DefaultPlexusContainer container = new DefaultPlexusContainer(cc, getCustomModule(context, exports)); // NOTE: To avoid inconsistencies, we'll use the TCCL exclusively for lookups container.setLookupRealm(null); Thread.currentThread().setContextClassLoader(container.getContainerRealm());
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Thu Jul 03 14:18:26 GMT 2025 - 14.3K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilJvm.kt
/** Dispatcher is not [Lockable] because we don't want that type in our public API. */ internal fun Dispatcher.assertLockNotHeld() { if (assertionsEnabled && Thread.holdsLock(this)) { throw AssertionError("Thread ${Thread.currentThread().name} MUST NOT hold lock on $this") } } /** * Returns the string "OkHttp" unless the library has been shaded for inclusion in another library,
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 10.2K bytes - Click Count (1) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java
ClassLoader oldClassLoader = Thread.currentThread().getContextClassLoader(); Thread.currentThread().setContextClassLoader(classLoader); try { Class<?> test = classLoader.loadClass(AbstractFutureTest.class.getName()); test.getMethod(getName()).invoke(test.getDeclaredConstructor().newInstance()); } finally { Thread.currentThread().setContextClassLoader(oldClassLoader); }
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 18:46:00 GMT 2025 - 7.3K bytes - Click Count (0) -
compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java
static final ThreadGroup GROUP = new ThreadGroup(THREADGROUP_NAME); static final AtomicInteger THREAD_NUMBER = new AtomicInteger(1); @Override public Thread newThread(Runnable r) { Thread newThread = new Thread(GROUP, r, "resolver-" + THREAD_NUMBER.getAndIncrement()); newThread.setDaemon(true); newThread.setContextClassLoader(null); return newThread; }
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 25K bytes - Click Count (0) -
.github/workflows/validate-codeowners.yml
steps: - name: Get Secrets uses: gradle/actions-internal/get-aws-secrets@v1 if: (github.event_name != 'pull_request' && github.repository_owner == 'gradle') || github.event.pull_request.head.repo.full_name == github.repository with: role-to-assume: arn:aws:iam::992382829881:role/GHASecrets_gradle_all secret-ids: |Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Thu Nov 20 22:15:20 GMT 2025 - 1.5K bytes - Click Count (0)