- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 1,285 for threaded (0.16 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/CallablesTest.java
public @Nullable Void call() throws Exception { assertEquals(Thread.currentThread().getName(), newName.get()); return null; } }; Callables.threadRenaming(callable, newName).call(); assertEquals(oldName, Thread.currentThread().getName()); } @J2ktIncompatible @GwtIncompatible // threads public void testRenaming_exceptionalReturn() throws Exception {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 5.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/CallablesTest.java
public @Nullable Void call() throws Exception { assertEquals(Thread.currentThread().getName(), newName.get()); return null; } }; Callables.threadRenaming(callable, newName).call(); assertEquals(oldName, Thread.currentThread().getName()); } @J2ktIncompatible @GwtIncompatible // threads public void testRenaming_exceptionalReturn() throws Exception {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 5.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/Connection.java
* * <p>Implementations are not guaranteed to be completely thread-safe. * However, the implementations: * <ul> * <li>should allow separate threads for dispatching and receiving, i.e. single thread that dispatches * and a different single thread that receives should be perfectly safe</li> * <li>should allow stopping or requesting stopping from a different thread than receiving/dispatching</li>
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 1.4K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/ConcurrentSpec.groovy
/** * A specification that uses multiple test threads. Provides an {@link Executor} and {@link org.gradle.internal.concurrent.ExecutorFactory} implementation. * * <p>This class maintains a set of instants reached by the test. An instant records the point in time that a test thread reached a certain point of its execution.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 3.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
} } }); awaitUninterruptibly(enteredLatch); } @CanIgnoreReturnValue static Thread startThread(Runnable runnable) { Thread thread = new Thread(runnable); thread.setDaemon(true); thread.start(); return thread; } /** * Generates a test case verifying that calling any enterXxx, tryEnterXxx, or waitForXxx method
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 25.8K bytes - Viewed (0) -
platforms/core-runtime/serialization/src/test/groovy/org/gradle/internal/serialize/DefaultSerializerRegistrySpec.groovy
def "invoking DefaultSerializerRegistry from multiple threads"() { given: def conditions = new AsyncConditions(numThreads) def serializer = Stub(Serializer) numThreads.times { threadId -> Thread.startDaemon("DefaultSerializerRegistry Test #$threadId") { conditions.evaluate { serializableClasses.forEach { theClass ->
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 15 16:06:56 UTC 2024 - 10.1K bytes - Viewed (0) -
platforms/ide/tooling-api/src/integTest/groovy/org/gradle/integtests/tooling/ConcurrentToolingApiIntegrationSpec.groovy
then: concurrent.finished() //only one thread should log that progress message 1 == allProgress.count { it.contains("Wait for the other thread to finish acquiring the distribution") } } def "during model building receives distribution progress"() { given: threads.times { idx -> file("build$idx/build.gradle") << "apply plugin: 'java'"
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 13.7K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/WorkerThreadRegistry.java
/** * Allows a thread to enlist in resource locking, for example to lock the mutable state of a project. */ @ServiceScope(Scope.BuildSession.class) public interface WorkerThreadRegistry { /** * Runs the given action as a worker. While the action is running, the thread can acquire resource locks. * A worker lease is also granted to the thread. The thread can release this if it needs to, but should reacquire
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 3.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestThread.java
start(); } // Thread.stop() is okay because all threads started by a test are dying at the end of the test, // so there is no object state put at risk by stopping the threads abruptly. In some cases a test // may put a thread into an uninterruptible operation intentionally, so there is no other way to // clean up these threads. @SuppressWarnings("deprecation") @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
/** Checks that the threads do not terminate within the given millisecond delay. */ void assertThreadsStayAlive(long millis, Thread... threads) { try { // No need to optimize the failing case via Thread.join. delay(millis); for (Thread thread : threads) assertTrue(thread.isAlive()); } catch (InterruptedException ie) { fail("Unexpected InterruptedException"); } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 37.7K bytes - Viewed (0)