- Sort Score
- Result 10 results
- Languages All
Results 31 - 35 of 35 for WriteLock (2.23 sec)
-
src/os/file_plan9.go
// It returns the number of bytes written and an error, if any. // Since Plan 9 preserves message boundaries, never allow // a zero-byte write. func (f *File) write(b []byte) (n int, err error) { if err := f.writeLock(); err != nil { return 0, err } defer f.writeUnlock() if len(b) == 0 { return 0, nil } return fixCount(syscall.Write(f.fd, b)) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 30 15:35:30 UTC 2024 - 16K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Striped.java
} @Override public Lock readLock() { return new WeakSafeLock(delegate.readLock(), this); } @Override public Lock writeLock() { return new WeakSafeLock(delegate.writeLock(), this); } } /** Lock object that ensures a strong reference is retained to a specified object. */ private static final class WeakSafeLock extends ForwardingLock {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 10 20:55:18 UTC 2023 - 20.3K bytes - Viewed (0) -
src/internal/poll/splice_linux.go
// all of it to the socket. This behavior is similar to the Write // step of an io.Copy in userspace. func splicePump(sock *FD, pipefd int, inPipe int) (int, error) { if err := sock.writeLock(); err != nil { return 0, err } defer sock.writeUnlock() if err := sock.pd.prepareWrite(sock.isFile); err != nil { return 0, err } written := 0 for inPipe > 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 7.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Striped.java
} @Override public Lock readLock() { return new WeakSafeLock(delegate.readLock(), this); } @Override public Lock writeLock() { return new WeakSafeLock(delegate.writeLock(), this); } } /** Lock object that ensures a strong reference is retained to a specified object. */ private static final class WeakSafeLock extends ForwardingLock {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 10 20:55:18 UTC 2023 - 20.3K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/MojoExecutor.java
if (session.getRequest().getDegreeOfConcurrency() > 1) { boolean aggregator = mojoDescriptor.isAggregator(); acquiredAggregatorLock = aggregator ? aggregatorLock.writeLock() : aggregatorLock.readLock(); acquiredProjectLock = getProjectLock(session); if (!acquiredAggregatorLock.tryLock()) { Thread owner = aggregatorLock.getOwner();
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Feb 28 23:31:09 UTC 2024 - 20.7K bytes - Viewed (0)