Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 462 for blocked (0.21 sec)

  1. src/runtime/runtime2.go

    	preemptoff    string // if != "", keep curg running on this m
    	locks         int32
    	dying         int32
    	profilehz     int32
    	spinning      bool // m is out of work and is actively looking for work
    	blocked       bool // m is blocked on a note
    	newSigstack   bool // minit on C thread called sigaltstack
    	printlock     int8
    	incgo         bool          // m is executing a cgo call
    	isextra       bool          // m is an extra m
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:37 UTC 2024
    - 47.9K bytes
    - Viewed (0)
  2. src/runtime/signal_unix.go

    	}
    }
    
    // blockableSig reports whether sig may be blocked by the signal mask.
    // We never want to block the signals marked _SigUnblock;
    // these are the synchronous signals that turn into a Go panic.
    // We never want to block the preemption signal if it is being used.
    // In a Go program--not a c-archive/c-shared--we never want to block
    // the signals marked _SigKill or _SigThrow, as otherwise it's possible
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 10 16:04:54 UTC 2024
    - 45K bytes
    - Viewed (0)
  3. src/runtime/rwmutex.go

    func (rw *rwmutex) unlock() {
    	// Announce to readers that there is no active writer.
    	r := rw.readerCount.Add(rwmutexMaxReaders)
    	if r >= rwmutexMaxReaders {
    		throw("unlock of unlocked rwmutex")
    	}
    	// Unblock blocked readers.
    	lock(&rw.rLock)
    	for rw.readers.ptr() != nil {
    		reader := rw.readers.ptr()
    		rw.readers = reader.schedlink
    		reader.schedlink.set(nil)
    		notewakeup(&reader.park)
    		r -= 1
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 22 14:29:04 UTC 2024
    - 5K bytes
    - Viewed (0)
  4. src/internal/trace/event/go122/event.go

    	EvGoBlock             // goroutine blocks [timestamp, reason, stack ID]
    	EvGoUnblock           // goroutine is unblocked [timestamp, goroutine ID, goroutine seq, stack ID]
    	EvGoSyscallBegin      // syscall enter [timestamp, P seq, stack ID]
    	EvGoSyscallEnd        // syscall exit [timestamp]
    	EvGoSyscallEndBlocked // syscall exit and it blocked at some point [timestamp]
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  5. src/cmd/go/internal/lockedfile/lockedfile_test.go

    	})
    
    	// Wait until process Q has either failed or locked file B.
    	// Otherwise, P.2 might not block on file B as intended.
    locked:
    	for {
    		if _, err := os.Stat(filepath.Join(dir, "locked")); !os.IsNotExist(err) {
    			break locked
    		}
    		timer := time.NewTimer(1 * time.Millisecond)
    		select {
    		case <-qDone:
    			timer.Stop()
    			break locked
    		case <-timer.C:
    		}
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Sep 05 23:35:29 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

        //            (__)\       )\/\
        //                ||----w |
        //                ||     ||
        Runnable state = get();
        Blocker blocker = null;
        while (state instanceof Blocker || state == PARKED) {
          if (state instanceof Blocker) {
            blocker = (Blocker) state;
          }
          spinCount++;
          if (spinCount > MAX_BUSY_WAIT_SPINS) {
            /*
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Sep 29 21:34:48 UTC 2023
    - 9.9K bytes
    - Viewed (0)
  7. src/runtime/os_windows.go

    				// Don't profile ourselves.
    				continue
    			}
    
    			lock(&mp.threadLock)
    			// Do not profile threads blocked on Notes,
    			// this includes idle worker threads,
    			// idle timer thread, idle heap scavenger, etc.
    			if mp.thread == 0 || mp.profilehz == 0 || mp.blocked {
    				unlock(&mp.threadLock)
    				continue
    			}
    			// Acquire our own handle to the thread.
    			var thread uintptr
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 22:55:25 UTC 2024
    - 41.5K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/InterruptibleTask.java

        //            (__)\       )\/\
        //                ||----w |
        //                ||     ||
        Runnable state = get();
        Blocker blocker = null;
        while (state instanceof Blocker || state == PARKED) {
          if (state instanceof Blocker) {
            blocker = (Blocker) state;
          }
          spinCount++;
          if (spinCount > MAX_BUSY_WAIT_SPINS) {
            /*
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Sep 29 21:34:48 UTC 2023
    - 9.9K bytes
    - Viewed (0)
  9. src/os/signal/doc.go

    entirely.
    
    If the program is started with a non-empty signal mask, some signals
    will be explicitly unblocked as described above. If Notify is called
    for a blocked signal, it will be unblocked. If, later, Reset is
    called for that signal, or Stop is called on all channels passed to
    Notify for that signal, the signal will once again be blocked.
    
    # SIGPIPE
    
    When a Go program writes to a broken pipe, the kernel will raise a
    SIGPIPE signal.
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 18:11:00 UTC 2024
    - 11K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/mutating_work_estimator.go

    		//   if currently unoccupied seats would allow for dispatching some
    		//   other requests in the meantime
    		// As a consequence of these, the wider the request, the more capacity
    		// will effectively be blocked and unused during dispatching and
    		// executing this request.
    		//
    		// To mitigate the impact of it, we're capping the maximum number of
    		// seats that can be assigned to a given request. Thanks to it:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 17 19:26:52 UTC 2023
    - 6K bytes
    - Viewed (0)
Back to top