Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 504 for chan2 (0.09 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. test/gcgort.go

    	case a.mapT == nil:
    		return errors.New(a.name + " missing mapT")
    	case a.mapPointerKeyT == nil:
    		return errors.New(a.name + " missing mapPointerKeyT")
    	case a.chanT == nil:
    		return errors.New(a.name + " missing chanT")
    	case a.interfaceT == nil:
    		return errors.New(a.name + " missing interfaceT")
    	default:
    		return nil
    	}
    }
    
    var types = []modifier{
    	modifier{
    		name: "bool",
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 08 21:15:48 UTC 2018
    - 34.5K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. src/go/printer/testdata/declarations.input

    func _() (x int)
    func _() (x (int))
    func _() (x (((((int))))))
    
    // special cases: some channel types require parentheses
    func _(x chan(<-chan int))
    func _(x (chan(<-chan int)))
    func _(x ((((chan(<-chan int))))))
    
    func _(x chan<-(chan int))
    func _(x (chan<-(chan int)))
    func _(x ((((chan<-(chan int))))))
    
    // don't introduce comma after last parameter if the closing ) is on the same line
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 13 22:24:31 UTC 2021
    - 16.5K bytes
    - Viewed (0)
Back to top