Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 481 for chan2 (0.23 sec)

  1. src/go/parser/parser_test.go

    	{name: "pointer", format: "package main; var x «*»int"},
    	{name: "func", format: "package main; var x «func()»int", scope: true},
    	{name: "chan", format: "package main; var x «chan »int"},
    	{name: "chan2", format: "package main; var x «<-chan »int"},
    	{name: "interface", format: "package main; var x «interface { M() «int» }»", scope: true, scopeMultiplier: 2}, // Scopes: InterfaceType, FuncType
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 31 20:26:14 UTC 2024
    - 24.6K bytes
    - Viewed (0)
  2. src/runtime/chan.go

    	dataqsiz uint           // size of the circular queue
    	buf      unsafe.Pointer // points to an array of dataqsiz elements
    	elemsize uint16
    	closed   uint32
    	timer    *timer // timer feeding this chan
    	elemtype *_type // element type
    	sendx    uint   // send index
    	recvx    uint   // receive index
    	recvq    waitq  // list of recv waiters
    	sendq    waitq  // list of send waiters
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:16:50 UTC 2024
    - 25.9K bytes
    - Viewed (0)
  3. src/runtime/chan_test.go

    	defer runtime.GOMAXPROCS(runtime.GOMAXPROCS(10))
    	var c [4]chan int
    	c[0] = make(chan int)
    	c[1] = make(chan int)
    	c[2] = make(chan int, 2)
    	c[3] = make(chan int, 3)
    	N := int(1e5)
    	if testing.Short() {
    		N /= 10
    	}
    	// There are 4 goroutines that send N values on each of the chans,
    	// + 4 goroutines that receive N values on each of the chans,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Oct 31 20:47:35 UTC 2023
    - 23.4K bytes
    - Viewed (0)
  4. src/runtime/race/testdata/chan_test.go

    	go func() {
    		close(c)
    		compl <- true
    	}()
    	c = make(chan int)
    	<-compl
    }
    
    func TestRaceChanItselfLen(t *testing.T) {
    	compl := make(chan bool, 1)
    	c := make(chan int)
    	go func() {
    		_ = len(c)
    		compl <- true
    	}()
    	c = make(chan int)
    	<-compl
    }
    
    func TestRaceChanItselfCap(t *testing.T) {
    	compl := make(chan bool, 1)
    	c := make(chan int)
    	go func() {
    		_ = cap(c)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jul 18 19:55:29 UTC 2023
    - 11K bytes
    - Viewed (0)
  5. cmd/kube-proxy/app/server_test.go

    func Test_getNodeIPs(t *testing.T) {
    	var chans [3]chan error
    
    	client := clientsetfake.NewSimpleClientset(
    		// node1 initially has no IP address.
    		makeNodeWithAddress("node1", ""),
    
    		// node2 initially has an invalid IP address.
    		makeNodeWithAddress("node2", "invalid-ip"),
    
    		// node3 initially does not exist.
    	)
    
    	for i := range chans {
    		chans[i] = make(chan error)
    		ch := chans[i]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 32.3K bytes
    - Viewed (0)
  6. src/runtime/select.go

    }
    
    // These values must match ../reflect/value.go:/SelectDir.
    type selectDir int
    
    const (
    	_             selectDir = iota
    	selectSend              // case Chan <- Send
    	selectRecv              // case <-Chan:
    	selectDefault           // default
    )
    
    //go:linkname reflect_rselect reflect.rselect
    func reflect_rselect(cases []runtimeSelect) (int, bool) {
    	if len(cases) == 0 {
    		block()
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Mar 13 21:36:04 UTC 2024
    - 15K bytes
    - Viewed (0)
  7. src/runtime/race/testdata/mop_test.go

    func TestRaceForTest(t *testing.T) {
    	done := make(chan bool)
    	c := make(chan bool)
    	stop := false
    	go func() {
    		for {
    			_, ok := <-c
    			if !ok {
    				done <- true
    				return
    			}
    			stop = true
    		}
    	}()
    	for !stop {
    		c <- true
    	}
    	close(c)
    	<-done
    }
    
    func TestRaceForIncr(t *testing.T) {
    	done := make(chan bool)
    	c := make(chan bool)
    	x := 0
    	go func() {
    		for {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 23 16:46:25 UTC 2023
    - 28.9K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apimachinery/pkg/util/wait/wait_test.go

    	if used != 0 {
    		t.Errorf("Expected exactly zero ticks, got %d", used)
    	}
    }
    
    func TestPollForever(t *testing.T) {
    	ch := make(chan struct{})
    	errc := make(chan error, 1)
    	done := make(chan struct{}, 1)
    	complete := make(chan struct{})
    	go func() {
    		f := ConditionFunc(func() (bool, error) {
    			ch <- struct{}{}
    			select {
    			case <-done:
    				return true, nil
    			default:
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 26 16:28:45 UTC 2024
    - 41.1K bytes
    - Viewed (0)
  9. src/runtime/proc_test.go

    			// iteration is 2 * (runtime overhead + chan
    			// send/receive pair + delay + wakeDelay). This allows
    			// the runtime overhead, including the time it takes
    			// for the unblocked goroutine to be scheduled, to be
    			// estimated.
    			ping, pong := make(chan struct{}), make(chan struct{})
    			start := make(chan struct{})
    			done := make(chan struct{})
    			go func() {
    				<-start
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jun 14 00:03:57 UTC 2023
    - 25.8K bytes
    - Viewed (0)
  10. src/go/parser/short_test.go

    	`package p; import "fmt"; func f() { fmt.Println("Hello, World!") };`,
    	`package p; func f() { if f(T{}) {} };`,
    	`package p; func f() { _ = <-chan int(nil) };`,
    	`package p; func f() { _ = (<-chan int)(nil) };`,
    	`package p; func f() { _ = (<-chan <-chan int)(nil) };`,
    	`package p; func f() { _ = <-chan <-chan <-chan <-chan <-int(nil) };`,
    	`package p; func f(func() func() func());`,
    	`package p; func f(...T);`,
    	`package p; func f(float, ...int);`,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Nov 02 12:56:53 UTC 2023
    - 10.1K bytes
    - Viewed (0)
Back to top