- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 35 for WriteLock (1.82 sec)
-
src/internal/poll/file_plan9.go
} func (fdmu *FDMutex) ReadLock() bool { return fdmu.fdmu.rwlock(true) } func (fdmu *FDMutex) ReadUnlock() bool { return fdmu.fdmu.rwunlock(true) } func (fdmu *FDMutex) WriteLock() bool { return fdmu.fdmu.rwlock(false) } func (fdmu *FDMutex) WriteUnlock() bool { return fdmu.fdmu.rwunlock(false)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Oct 08 03:57:40 UTC 2022 - 972 bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java
Lock readLock = striped.get(key).readLock(); WeakReference<Object> garbage = new WeakReference<>(new Object()); GcFinalization.awaitClear(garbage); Lock writeLock = striped.get(key).writeLock(); readLock.lock(); assertFalse(writeLock.tryLock()); readLock.unlock(); } @AndroidIncompatible // Presumably GC doesn't trigger, despite our efforts. public void testStrongImplementations() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 09 22:57:07 UTC 2022 - 8.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/StripedTest.java
Lock readLock = striped.get(key).readLock(); WeakReference<Object> garbage = new WeakReference<>(new Object()); GcFinalization.awaitClear(garbage); Lock writeLock = striped.get(key).writeLock(); readLock.lock(); assertFalse(writeLock.tryLock()); readLock.unlock(); } @AndroidIncompatible // Presumably GC doesn't trigger, despite our efforts. public void testStrongImplementations() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 09 22:57:07 UTC 2022 - 8.4K bytes - Viewed (0) -
analysis/analysis-api-standalone/analysis-api-standalone-base/src/org/jetbrains/kotlin/analysis/api/standalone/base/project/structure/ApplicationServiceRegistration.kt
) { for (registrar in registrars) { if (lock.readLock().withLock { application.isRegistrarRegistered(registrar) }) { continue } lock.writeLock().withLock { if (application.isRegistrarRegistered(registrar)) return@withLock registrar.register() application.serviceRegistered[registrar::class] = true }
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Thu May 16 11:53:35 UTC 2024 - 3K bytes - Viewed (0) -
src/internal/poll/sendfile_solaris.go
func SendFile(dstFD *FD, src int, pos, remain int64) (written int64, err error, handled bool) { defer func() { TestHookDidSendFile(dstFD, src, written, err, handled) }() if err := dstFD.writeLock(); err != nil { return 0, err, false } defer dstFD.writeUnlock() if err := dstFD.pd.prepareWrite(dstFD.isFile); err != nil { return 0, err, false } dst := dstFD.Sysfd for remain > 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 1.8K bytes - Viewed (0) -
src/cmd/go/internal/lockedfile/internal/filelock/filelock_windows.go
//go:build windows package filelock import ( "internal/syscall/windows" "io/fs" "syscall" ) type lockType uint32 const ( readLock lockType = 0 writeLock lockType = windows.LOCKFILE_EXCLUSIVE_LOCK ) const ( reserved = 0 allBytes = ^uint32(0) ) func lock(f File, lt lockType) error { // Per https://golang.org/issue/19098, “Programs currently expect the Fd
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 17 02:24:35 UTC 2023 - 1.3K bytes - Viewed (0) -
.teamcity/src/main/kotlin/promotion/BasePromotionBuildType.kt
// we only allow 1 promotion job running at the same time to avoid website xml conflicts feature { type = "JetBrains.SharedResources" param("locks-param", "WebsiteReleasesXml writeLock") } } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 24 03:34:53 UTC 2024 - 2.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java
this.writeLock = new CycleDetectingReentrantWriteLock(this); this.lockGraphNode = Preconditions.checkNotNull(lockGraphNode); } ///// Overridden ReentrantReadWriteLock methods. ///// @Override public ReadLock readLock() { return readLock; } @Override public WriteLock writeLock() { return writeLock; }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Dec 15 19:31:54 UTC 2023 - 35.9K bytes - Viewed (0) -
src/internal/poll/sendfile_bsd.go
func SendFile(dstFD *FD, src int, pos, remain int64) (written int64, err error, handled bool) { defer func() { TestHookDidSendFile(dstFD, src, written, err, handled) }() if err := dstFD.writeLock(); err != nil { return 0, err, false } defer dstFD.writeUnlock() if err := dstFD.pd.prepareWrite(dstFD.isFile); err != nil { return 0, err, false } dst := dstFD.Sysfd for remain > 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 1.5K bytes - Viewed (0) -
src/internal/poll/writev.go
//go:build unix package poll import ( "io" "runtime" "syscall" ) // Writev wraps the writev system call. func (fd *FD) Writev(v *[][]byte) (int64, error) { if err := fd.writeLock(); err != nil { return 0, err } defer fd.writeUnlock() if err := fd.pd.prepareWrite(fd.isFile); err != nil { return 0, err } var iovecs []syscall.Iovec if fd.iovecs != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 27 18:23:49 UTC 2024 - 1.8K bytes - Viewed (0)