Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for numblocks (0.15 sec)

  1. android/guava/src/com/google/common/util/concurrent/OverflowAvoidingLockSupport.java

      private OverflowAvoidingLockSupport() {}
    
      static void parkNanos(@CheckForNull Object blocker, long nanos) {
        // Even in the extremely unlikely event that a thread unblocks itself early after only 68 years,
        // this is indistinguishable from a spurious wakeup, which LockSupport allows.
        LockSupport.parkNanos(blocker, min(nanos, MAX_NANOSECONDS_THRESHOLD));
      }
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 1.6K bytes
    - Viewed (0)
  2. internal/grid/muxserver.go

    	if msg.DeadlineMS == 0 || msg.DeadlineMS > uint32(lastPingThreshold/time.Millisecond) {
    		go func() {
    			wg.Wait()
    			m.checkRemoteAlive()
    		}()
    	}
    	return &m
    }
    
    // handleInbound sends unblocks when we have delivered the message to the handler.
    func (m *muxServer) handleInbound(c *Connection, inbound <-chan []byte, handlerIn chan<- []byte) {
    	for in := range inbound {
    		handlerIn <- in
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.1K bytes
    - Viewed (0)
Back to top