- Sort Score
- Result 10 results
- Languages All
Results 21 - 27 of 27 for semacquire (3.79 sec)
-
src/runtime/mgcwork.go
} wbuf.nobj-- return wbuf.obj[wbuf.nobj] } // dispose returns any cached pointers to the global queue. // The buffers are being put on the full queue so that the // write barriers will not simply reacquire them before the // GC can inspect them. This helps reduce the mutator's // ability to hide pointers during the concurrent mark phase. // //go:nowritebarrierrec func (w *gcWork) dispose() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 12.9K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/DefaultWorkerLeaseServiceProjectLockTest.groovy
assert lockIsHeld(taskLease) assert lockIsHeld(projectLock) } !lockIsHeld(taskLease) !lockIsHeld(projectLock) } def "can release and reacquire project lock while holding task execution lease"() { def workerLeaseService = workerLeaseService(false) def taskLease = workerLeaseService.getTaskExecutionLock(path("build"), path("project"))
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 25.6K bytes - Viewed (0) -
src/runtime/metrics.go
} func metricsLock() { // Acquire the metricsSema but with handoff. Operations are typically // expensive enough that queueing up goroutines and handing off between // them will be noticeably better-behaved. semacquire1(&metricsSema, true, 0, 0, waitReasonSemacquire) if raceenabled { raceacquire(unsafe.Pointer(&metricsSema)) } } func metricsUnlock() { if raceenabled { racerelease(unsafe.Pointer(&metricsSema)) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 08 21:03:13 UTC 2024 - 26K bytes - Viewed (0) -
src/runtime/traceruntime.go
// true in the following cases: // - The goroutine lost its P, it ran some other code, and then got it back. It's now running with that P. // - The goroutine lost its P and was unable to reacquire it, and is now running without a P. // - The goroutine lost its P and acquired a different one, and is now running with that P. func (tl traceLocker) GoSysExit(lostP bool) { ev := traceEvGoSyscallEnd
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:31:00 UTC 2024 - 25.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Monitor.java
* signal the first active guard that is satisfied. But the corresponding thread may have already * been interrupted and is waiting to reacquire the lock while still registered in activeGuards, * in which case the signal is a no-op, and the bigger-picture signal is lost unless interrupted * threads take special action by participating in the signal-passing game.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 18:22:01 UTC 2023 - 38.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Monitor.java
* signal the first active guard that is satisfied. But the corresponding thread may have already * been interrupted and is waiting to reacquire the lock while still registered in activeGuards, * in which case the signal is a no-op, and the bigger-picture signal is lost unless interrupted * threads take special action by participating in the signal-passing game.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 18:22:01 UTC 2023 - 42.5K bytes - Viewed (0) -
src/testing/testing.go
err := t.runCleanup(recoverAndReturnPanic) t.duration += highPrecisionTimeSince(cleanupStart) if err != nil { doPanic(err) } t.checkRaces() if !t.isParallel { // Reacquire the count for sequential tests. See comment in Run. t.context.waitParallel() } } else if t.isParallel { // Only release the count for this test if it was run as a parallel
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 76.1K bytes - Viewed (0)