- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 504 for chan2 (0.09 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)