- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 928 for lock1 (0.03 sec)
-
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonClientConnection.java
import org.gradle.launcher.daemon.context.DaemonConnectDetails; import org.gradle.launcher.daemon.protocol.Message; import javax.annotation.Nullable; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; /** * A simple wrapper for the connection to a daemon. * * <p>Currently, dispatch is thread safe, and receive is not. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 30 06:43:50 UTC 2024 - 4.2K bytes - Viewed (0) -
src/cmd/go/internal/lockedfile/internal/filelock/filelock.go
// ensure that Unlock is always called when Lock succeeds. func Lock(f File) error { return lock(f, writeLock) } // RLock places an advisory read lock on the file, blocking until it can be locked. // // If RLock returns nil, no other process will be able to place a write lock on // the file until this process exits, closes f, or calls Unlock on it. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 17 02:24:35 UTC 2023 - 2.6K bytes - Viewed (0) -
cmd/bucket-object-lock.go
return ObjectLocked{} } if !ret.RetainUntilDate.Before(t) { return ObjectLocked{} } return nil } // https://docs.aws.amazon.com/AmazonS3/latest/dev/object-lock-overview.html#object-lock-retention-modes // If you try to delete objects protected by governance mode and have s3:BypassGovernanceRetention, the operation will succeed.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 13.2K bytes - Viewed (0) -
cmd/lock-rest-client.go
default: err = errors.New(r.Err) } return ok, err } // RLock calls read lock REST API. func (c *lockRESTClient) RLock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) { return c.call(ctx, lockRPCRLock, &args) } // Lock calls lock REST API. func (c *lockRESTClient) Lock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) { return c.call(ctx, lockRPCLock, &args) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Nov 24 17:07:14 UTC 2023 - 3.3K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/ConcurrentTestUtil.groovy
private final List<TestParticipant> participants private final Lock lock CompositeTestParticipant(ConcurrentTestUtil owner, Lock lock, List<TestParticipant> participants) { super(owner) this.participants = participants this.lock = lock } void running() { lock.lock() try { participants*.running() } finally {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 22.9K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/api/internal/initialization/DefaultBuildLogicBuildQueue.java
} @SuppressWarnings("try") private <T> T withBuildLogicQueueLock(Supplier<T> buildAction) { lock.lock(); try { final boolean firstLockHolder = lock.getHoldCount() == 1; if (firstLockHolder) { // lock file at the top of the callstack only try (FileLock ignored = lockBuildLogicQueueFile()) { return buildAction.get();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Feb 16 23:00:15 UTC 2024 - 3.8K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/queue/MultiEndPointQueue.java
private final List<EndPointQueue> waiting = new ArrayList<EndPointQueue>(); private final Lock lock; private final QueueInitializer initializer = new QueueInitializer(); public MultiEndPointQueue(Lock lock) { this.lock = lock; } @Override public void dispatch(InterHubMessage message) { queue.add(message); flush(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 3.9K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/work/DefaultAsyncWorkTracker.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 6K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectMaxNConcurrentRequests.java
import java.util.LinkedList; import java.util.List; import java.util.concurrent.TimeUnit; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; class ExpectMaxNConcurrentRequests implements TrackingHttpHandler, WaitPrecondition, BlockingHttpServer.BlockingHandler { private final Lock lock; private final Condition condition; private final List<ResourceHandlerWrapper> received = new ArrayList<>();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 14.4K bytes - Viewed (0) -
cmd/namespace-lock_test.go
// successfully acquiring the lock. // 2) lk2 then needs to advance and remove the resource from lockMap. // 3) lk3 or lk4 (whichever didn't execute in step 1) then executes and creates // a new entry in lockMap and acquires a lock for the same resource. <-lk2ch lk3ok := <-lk3ch lk4ok := <-lk4ch if lk3ok && lk4ok { t.Fatalf("multiple locks acquired; iteration=%d, lk3=%t, lk4=%t", i, lk3ok, lk4ok)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Apr 23 18:58:53 UTC 2021 - 3.1K bytes - Viewed (0)