Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 34 for MakeOp (0.25 sec)

  1. src/runtime/select.go

    			} else {
    				c.recvq.dequeueSudoG(sglist)
    			}
    		}
    		sgnext = sglist.waitlink
    		sglist.waitlink = nil
    		releaseSudog(sglist)
    		sglist = sgnext
    	}
    
    	if cas == nil {
    		throw("selectgo: bad wakeup")
    	}
    
    	c = cas.c
    
    	if debugSelect {
    		print("wait-return: cas0=", cas0, " c=", c, " cas=", cas, " send=", casi < nsends, "\n")
    	}
    
    	if casi < nsends {
    		if !caseSuccess {
    			goto sclose
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Mar 13 21:36:04 UTC 2024
    - 15K bytes
    - Viewed (0)
  2. src/internal/trace/internal/oldtrace/parser.go

    	EvTimerGoroutine    event.Type = 35 // denotes timer goroutine [timer goroutine id]
    	EvFutileWakeup      event.Type = 36 // denotes that the previous wakeup of this goroutine was futile [timestamp]
    	EvString            event.Type = 37 // string dictionary entry [ID, length, string]
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 21:15:28 UTC 2024
    - 46.8K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

                    removeWaiter(node);
                    throw new InterruptedException();
                  }
    
                  // Otherwise re-read and check doneness. If we loop then it must have been a spurious
                  // wakeup
                  localValue = value;
                  if (localValue != null & !(localValue instanceof SetFuture)) {
                    return getDoneValue(localValue);
                  }
    
                  // timed out?
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 63.1K bytes
    - Viewed (1)
  6. guava/src/com/google/common/util/concurrent/AbstractFuture.java

                    removeWaiter(node);
                    throw new InterruptedException();
                  }
    
                  // Otherwise re-read and check doneness. If we loop then it must have been a spurious
                  // wakeup
                  localValue = value;
                  if (localValue != null & !(localValue instanceof SetFuture)) {
                    return getDoneValue(localValue);
                  }
    
                  // timed out?
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 62.8K bytes
    - Viewed (1)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top