- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 474 for lock1 (0.04 sec)
-
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/ProducerGuard.java
private final Striped<Lock> locks = Striped.lock(Runtime.getRuntime().availableProcessors() * 4); @Override public <V> V guardByKey(T key, Supplier<V> supplier) { Lock lock = locks.get(key); lock.lock(); try { return supplier.get(); } finally { lock.unlock(); } } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 26 16:02:31 UTC 2024 - 4.7K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/ResourceLockCoordinationService.java
* RETRY - One or more locks were not acquired, roll back any locks that were acquired and block waiting for the * state to change, then run the transform again * * @return true if the lock state changes finished successfully, otherwise false. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 06:02:18 UTC 2024 - 2.9K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/deployment/internal/SimpleBlockingDeployment.java
import javax.annotation.Nullable; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; class SimpleBlockingDeployment implements DeploymentInternal { private final Lock lock = new ReentrantLock(); private final Condition upToDate = lock.newCondition(); private final DeploymentInternal delegate;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Feb 23 18:00:07 UTC 2022 - 2.1K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/TestManagedExecutor.groovy
import java.util.concurrent.TimeUnit import java.util.concurrent.locks.Condition import java.util.concurrent.locks.Lock import java.util.concurrent.locks.ReentrantLock class TestManagedExecutor extends AbstractExecutorService implements ManagedExecutor { private final Lock lock = new ReentrantLock() private final Condition condition = lock.newCondition() private int count private final TestExecutor executor;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 2.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/deployment/internal/DefaultContinuousExecutionGate.java
import java.util.ArrayList; import java.util.List; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; public class DefaultContinuousExecutionGate implements ContinuousExecutionGate { private final Lock lock = new ReentrantLock(); private final Condition opened = lock.newCondition(); private final List<GateKeeper> gatekeepers = new ArrayList<>();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 3.2K bytes - Viewed (0) -
tensorflow/compiler/mlir/tf2xla/api/v1/testdata/prepare_to_library.mlir
"tf._XlaHostComputeMlir"(%0, %cst_34, %cst_63, %cst_33) <{host_mlir_module = "#loc1 = loc(\22Reshape:\22)\0A#loc2 = loc(\22Reshape_4\22)\0A#loc3 = loc(\22Reshape\22)\0A#loc9 = loc(fused[#loc1, #loc2, #loc3])\0Amodule {\0A func.func @host_func(%arg0: tensor<3360x?xi32> loc(fused[#loc1, #loc2, #loc3]), %arg1: tensor<3xi32> loc(fused[#loc1, #loc2, #loc3]), %arg2: tensor<i32> loc(fused[#loc1, #loc2, #loc3]), %arg3: tensor<2xi32> loc(fused[#loc1, #loc2, #loc3])) -> (tensor<1x1120x?xi32>, tensor<1x1120x?xi32>, tensor<1120x?xi32>,...
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Jan 31 23:44:50 UTC 2024 - 2.3K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/async/ServiceLifecycle.java
import java.util.Map; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; /** * Manages the lifecycle of some thread-safe service or resource. */ public class ServiceLifecycle implements AsyncStoppable { private enum State {RUNNING, STOPPING, STOPPED} private final String displayName; private final Lock lock = new ReentrantLock();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:55 UTC 2024 - 4K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/Synchronizer.java
import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; import java.util.function.Supplier; // TODO Replace the use of this with synchronized caches from Guava @NonNullApi public class Synchronizer { private final Lock lock = new ReentrantLock(); public <T> T synchronize(Supplier<T> factory) { lock.lock(); try { return factory.get();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 1.3K bytes - Viewed (0) -
internal/dsync/dsync-server_test.go
} } const WriteLock = -1 type lockServer struct { mutex sync.Mutex // Map of locks, with negative value indicating (exclusive) write lock // and positive values indicating number of read locks lockMap map[string]int64 // Refresh returns lock not found if set to true lockNotFound bool // Set to true if you want peers servers to do not respond responseDelay int64 }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jan 23 16:46:37 UTC 2023 - 8.3K bytes - Viewed (0) -
src/runtime/lock_sema.go
return atomic.Loaduintptr(&l.key) > locked } func lock(l *mutex) { lockWithRank(l, getLockRank(l)) } func lock2(l *mutex) { gp := getg() if gp.m.locks < 0 { throw("runtime·lock: lock count") } gp.m.locks++ // Speculative grab for lock. if atomic.Casuintptr(&l.key, 0, locked) { return } semacreate(gp.m) timer := &lockTimer{lock: l} timer.begin()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 6.8K bytes - Viewed (0)