Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for MakeOp (0.19 sec)

  1. guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

                } catch (InterruptedException ie) {
                  // continue
                }
                LockSupport.unpark(Thread.currentThread()); // simulate a spurious wakeup.
                return null;
              }
    
              @Override
              boolean isDone() {
                return false;
              }
    
              @Override
              String toPendingString() {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  2. src/runtime/netpoll_kqueue.go

    	return 0
    }
    
    func netpollarm(pd *pollDesc, mode int) {
    	throw("runtime: unused")
    }
    
    // netpollBreak interrupts a kevent.
    func netpollBreak() {
    	// Failing to cas indicates there is an in-flight wakeup, so we're done here.
    	if !netpollWakeSig.CompareAndSwap(0, 1) {
    		return
    	}
    
    	wakeNetpoll(kq)
    }
    
    // netpoll checks for ready network connections.
    // Returns list of goroutines that become runnable.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 12 21:17:22 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  3. src/runtime/lock_js.go

    	notesWithTimeout = make(map[*note]noteWithTimeout)
    )
    
    func noteclear(n *note) {
    	n.key = note_cleared
    }
    
    func notewakeup(n *note) {
    	// gp := getg()
    	if n.key == note_woken {
    		throw("notewakeup - double wakeup")
    	}
    	cleared := n.key == note_cleared
    	n.key = note_woken
    	if cleared {
    		goready(notes[n], 1)
    	}
    }
    
    func notesleep(n *note) {
    	throw("notesleep not supported by js")
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Nov 21 21:02:20 UTC 2023
    - 7.3K bytes
    - Viewed (0)
  4. src/sync/mutex.go

    		}
    	} else {
    		// Starving mode: handoff mutex ownership to the next waiter, and yield
    		// our time slice so that the next waiter can start to run immediately.
    		// Note: mutexLocked is not set, the waiter will set it after wakeup.
    		// But mutex is still considered locked if mutexStarving is set,
    		// so new coming goroutines won't acquire it.
    		runtime_Semrelease(&m.sema, true, 1)
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  5. src/runtime/tracecpu.go

    			// Sleep here because traceReadCPU is non-blocking. This mirrors
    			// how the runtime/pprof package obtains CPU profile data.
    			//
    			// We can't do a blocking read here because Darwin can't do a
    			// wakeup from a signal handler, so all CPU profiling is just
    			// non-blocking. See #61768 for more details.
    			//
    			// Like the runtime/pprof package, even if that bug didn't exist
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 17:03:35 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  6. src/runtime/netpoll_windows.go

    	// nothing to do
    	return 0
    }
    
    func netpollarm(pd *pollDesc, mode int) {
    	throw("runtime: unused")
    }
    
    func netpollBreak() {
    	// Failing to cas indicates there is an in-flight wakeup, so we're done here.
    	if !netpollWakeSig.CompareAndSwap(0, 1) {
    		return
    	}
    
    	key := packNetpollKey(netpollSourceBreak, nil)
    	if stdcall4(_PostQueuedCompletionStatus, iocphandle, 0, key, 0) == 0 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 26 19:58:28 UTC 2024
    - 9.4K bytes
    - Viewed (0)
Back to top