- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 928 for lock1 (0.04 sec)
-
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/SynchronizedDispatchConnection.java
import org.gradle.internal.remote.internal.RemoteConnection; import org.gradle.launcher.daemon.protocol.OutputMessage; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; /** * Connection decorator that synchronizes dispatching and always flushes after each message. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/service/scopes/DefaultGradleUserHomeScopeServiceRegistry.java
import java.io.Closeable; import java.io.File; import java.util.HashMap; import java.util.Map; import java.util.Optional; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 5.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestThread.java
* method equivalent to {@link * java.util.concurrent.locks.ReentrantLock#hasWaiters(java.util.concurrent.locks.Condition)}, * except that the method parameter must accept whatever condition-like object is passed into {@code * callAndAssertWaits} by the test. * * @param <L> the type of the lock-like object to be used * @author Justin T. Sampson */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/work/DefaultAsyncWorkTrackerTest.groovy
1 * workerLeaseService.runAsIsolatedTask() 1 * workerLeaseService.withoutLock(workerLease, _) >> { locks, Runnable runnable -> runnable.run() } 0 * workerLeaseService._ } def "does not release a project lock before waiting on async work when locks are retained"() { def workerLease = Mock(WorkerLeaseRegistry.WorkerLease) def workerLeaseService = Mock(WorkerLeaseService)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 06 04:53:10 UTC 2023 - 14.9K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/locking/DependencyLockingIntegrationTest.groovy
lockedConf 'org:bar:[1.0,2.0)' } """ when: succeeds 'dependencies', '--update-locks', 'org:foo' then: lockfileFixture.verifyLockfile('lockedConf', ['org:foo:1.1', 'org:bar:1.1']) } def 'does not write an empty lock file for an empty configuration if not requested'() { buildFile << """ dependencyLocking { lockAllConfigurations() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 30 12:42:25 UTC 2023 - 6.1K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/problems/DefaultProblemLocationAnalyzer.java
import java.util.Map; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; public class DefaultProblemLocationAnalyzer implements ProblemLocationAnalyzer, ClassLoaderScopeRegistryListener, Closeable { private static final StackFramePredicate GRADLE_CODE = (frame, relevance) -> InternalStackTraceClassifier.isGradleCall(frame.getClassName()); private final Lock lock = new ReentrantLock();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 23 17:15:42 UTC 2024 - 5.5K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultConditionalExecutionQueue.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:40 UTC 2024 - 7.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DefaultDaemonConnection.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 16K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/registry/PersistentDaemonRegistry.java
import org.gradle.launcher.daemon.context.DaemonContext; import java.io.File; import java.util.Collection; import java.util.LinkedList; import java.util.List; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; import static org.gradle.launcher.daemon.server.api.DaemonStateControl.State; import static org.gradle.launcher.daemon.server.api.DaemonStateControl.State.Canceled;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 8.9K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/DefaultPersistentDirectoryStoreTest.groovy
_ * lock.state 1 * lock.close() 0 * _._ } def "locks requested target"() { final store = new DefaultPersistentDirectoryStore(cacheDir, "<display>", mode(Shared), null, lockManager, Mock(ExecutorFactory), buildOperationRunner) when: store.open() then: 1 * lockManager.lock(cacheDir.file("."), mode(Shared), "<display> ($cacheDir)") >> lock
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 14 16:40:49 UTC 2024 - 5.9K bytes - Viewed (0)