- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 481 for chan2 (0.23 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) -
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/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) -
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)