- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,935 for thread1 (0.18 sec)
-
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) -
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) -
subprojects/core/src/testFixtures/groovy/org/gradle/internal/classpath/intercept/TestInterceptorsSubstitution.groovy
import javax.annotation.Nullable /** * Provides support for replacing the interceptors for the current thread. * Make sure that the call sites that should be affected by the change are only reached after the interceptors have been substituted. * * The interceptors are substituted per-thread because other threads may be executing unrelated tests. */ abstract class TestInterceptorsSubstitution<T> { private final T substitution
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 16 16:29:37 UTC 2023 - 3.3K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/ProjectLeaseRegistry.java
* thread to run as if it were executing an isolated task. * * Does not release worker lease. */ void runAsIsolatedTask(); /** * Returns {@code true} when this registry grants multiple threads access to projects (but no more than one thread per given project)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 5.4K bytes - Viewed (0) -
platforms/core-runtime/serialization/src/main/java/org/gradle/internal/serialize/StatefulSerializer.java
*/ package org.gradle.internal.serialize; /** * Implementations must allow concurrent reading and writing, so that a thread can read and a thread can write at the same time. * Implementations do not need to support multiple read threads or multiple write threads. */ public interface StatefulSerializer<T> { /** * Should not perform any buffering */ ObjectReader<T> newReader(Decoder decoder);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 15 16:06:56 UTC 2024 - 1.1K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/async/ServiceLifecycleTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:55 UTC 2024 - 6.2K 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) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
Registered: Wed Jun 12 12:50:12 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 8K 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)