Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 27 of 27 for semacquire (3.79 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top