Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 17 of 17 for MakeOp (0.11 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go

    	// As a result, the condition in the below for loop will never be
    	// satisfied (w.resourceVersion is never negative), this call will
    	// never hit the w.cond.Wait().
    	// As a result - we can optimize the code by not firing the wakeup
    	// function (and avoid starting a gorotuine), especially given that
    	// resourceVersion=0 is the most common case.
    	if resourceVersion > 0 {
    		go func() {
    			// Wake us up when the time limit has expired.  The docs
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 10:20:57 UTC 2024
    - 26.2K bytes
    - Viewed (0)
  2. src/time/sleep_test.go

    		samples += float64(s.count)
    	}
    	b.ReportMetric(0, "ns/op")
    	b.ReportMetric(total/samples, "avg-late-ns")
    	b.ReportMetric(float64(max.Nanoseconds()), "max-late-ns")
    }
    
    // Benchmark timer latency with staggered wakeup times and varying CPU bound
    // workloads. https://golang.org/issue/38860
    func BenchmarkStaggeredTickerLatency(b *testing.B) {
    	gmp := runtime.GOMAXPROCS(0)
    	if gmp < 2 || runtime.NumCPU() < gmp {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 22 16:33:57 UTC 2024
    - 22.5K bytes
    - Viewed (0)
  3. src/runtime/os_linux.go

    //
    //go:nosplit
    func futexwakeup(addr *uint32, cnt uint32) {
    	ret := futex(unsafe.Pointer(addr), _FUTEX_WAKE_PRIVATE, cnt, nil, nil, 0)
    	if ret >= 0 {
    		return
    	}
    
    	// I don't know that futex wakeup can return
    	// EAGAIN or EINTR, but if it does, it would be
    	// safe to loop and call futex again.
    	systemstack(func() {
    		print("futexwakeup addr=", addr, " returned ", ret, "\n")
    	})
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 25.9K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        waiter1.interrupt();
    
        waiter1.join();
        waiter2.awaitWaiting(); // should still be blocked
    
        LockSupport.unpark(waiter2); // spurious wakeup
        waiter2.awaitWaiting(); // should eventually re-park
    
        future.set(null);
        waiter2.join();
      }
    
      public void testRemoveWaiter_polling() throws Exception {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  5. src/runtime/chan.go

    	gp.param = nil
    	if mysg.releasetime > 0 {
    		blockevent(mysg.releasetime-t0, 2)
    	}
    	mysg.c = nil
    	releaseSudog(mysg)
    	if closed {
    		if c.closed == 0 {
    			throw("chansend: spurious wakeup")
    		}
    		panic(plainError("send on closed channel"))
    	}
    	return true
    }
    
    // send processes a send operation on an empty channel c.
    // The value ep sent by the sender is copied to the receiver sg.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:16:50 UTC 2024
    - 25.9K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        waiter1.interrupt();
    
        waiter1.join();
        waiter2.awaitWaiting(); // should still be blocked
    
        LockSupport.unpark(waiter2); // spurious wakeup
        waiter2.awaitWaiting(); // should eventually re-park
    
        future.set(null);
        waiter2.join();
      }
    
      public void testRemoveWaiter_polling() throws Exception {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  7. src/runtime/runtime2.go

    	lockRankStruct
    	// Futex-based impl treats it as uint32 key,
    	// while sema-based impl as M* waitm.
    	// Used to be a union, but unions break precise GC.
    	key uintptr
    }
    
    // sleep and wakeup on one-time events.
    // before any calls to notesleep or notewakeup,
    // must call noteclear to initialize the Note.
    // then, exactly one thread can call notesleep
    // and exactly one thread can call notewakeup (once).
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:37 UTC 2024
    - 47.9K bytes
    - Viewed (0)
Back to top