- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 695 for chan2 (0.03 sec)
-
src/internal/fmtsort/sort_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 6.9K bytes - Viewed (0) -
src/cmd/compile/internal/syntax/testdata/chans.go
func Ranger[T any]() (*Sender[T], *Receiver[T]) { c := make(chan T) d := make(chan bool) s := &Sender[T]{values: c, done: d} r := &Receiver[T]{values: c, done: d} runtime.SetFinalizer(r, r.finalize) return s, r } // A sender is used to send values to a Receiver. type Sender[T any] struct { values chan<- T done <-chan bool } // Send sends a value to the receiver. It returns whether any more
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 30 18:02:18 UTC 2022 - 1.8K bytes - Viewed (0) -
src/internal/types/testdata/check/chans.go
func Ranger[T any]() (*Sender[T], *Receiver[T]) { c := make(chan T) d := make(chan bool) s := &Sender[T]{values: c, done: d} r := &Receiver[T]{values: c, done: d} runtime.SetFinalizer(r, r.finalize) return s, r } // A sender is used to send values to a Receiver. type Sender[T any] struct { values chan<- T done <-chan bool } // Send sends a value to the receiver. It returns whether any more
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 02 02:58:32 UTC 2022 - 1.7K bytes - Viewed (0) -
test/typeparam/chans.go
// or the context is canceled, at which point the returned channel is closed. func _Merge[Elem any](ctx context.Context, c1, c2 <-chan Elem) <-chan Elem { r := make(chan Elem) go func(ctx context.Context, c1, c2 <-chan Elem, r chan<- Elem) { defer close(r) for c1 != nil || c2 != nil { select { case <-ctx.Done(): return case v1, ok := <-c1: if ok { r <- v1
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 01 19:45:34 UTC 2022 - 8.4K bytes - Viewed (0) -
src/go/types/chan.go
func NewChan(dir ChanDir, elem Type) *Chan { return &Chan{dir: dir, elem: elem} } // Dir returns the direction of channel c. func (c *Chan) Dir() ChanDir { return c.dir } // Elem returns the element type of channel c. func (c *Chan) Elem() Type { return c.elem } func (c *Chan) Underlying() Type { return c }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 03 18:48:38 UTC 2024 - 1K bytes - Viewed (0) -
src/cmd/cgo/internal/testlife/testdata/life.go
} } // Keep the channels visible from Go. var chans [4]chan bool // Double return value is just for testing. // //export GoStart func GoStart(i, xdim, ydim, xstart, xend, ystart, yend C.int, a *C.int, n *C.int) (int, int) { c := make(chan bool, int(C.MYCONST)) go func() { C.DoStep(xdim, ydim, xstart, xend, ystart, yend, a, n) c <- true }() chans[i] = c return int(i), int(i + 100) } //export GoWait
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 11:59:56 UTC 2023 - 892 bytes - Viewed (0) -
src/cmd/cgo/internal/testplugin/testdata/issue25756/plugin/life.go
} } // Keep the channels visible from Go. var chans [4]chan bool // Double return value is just for testing. // //export GoStart func GoStart(i, xdim, ydim, xstart, xend, ystart, yend C.int, a *C.int, n *C.int) (int, int) { c := make(chan bool, int(C.MYCONST)) go func() { C.DoStep(xdim, ydim, xstart, xend, ystart, yend, a, n) c <- true }() chans[i] = c return int(i), int(i + 100) } //export GoWait
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 11:59:56 UTC 2023 - 889 bytes - Viewed (0) -
src/internal/singleflight/singleflight.go
// results when they are ready. func (g *Group) DoChan(key string, fn func() (any, error)) <-chan Result { ch := make(chan Result, 1) g.mu.Lock() if g.m == nil { g.m = make(map[string]*call) } if c, ok := g.m[key]; ok { c.dups++ c.chans = append(c.chans, ch) g.mu.Unlock() return ch } c := &call{chans: []chan<- Result{ch}} c.wg.Add(1) g.m[key] = c g.mu.Unlock() go g.doCall(c, key, fn)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 30 20:49:56 UTC 2022 - 3.1K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/internal/typeparams/coretype.go
return U } ch, ok := U.(*types.Chan) if !ok { return nil // no core type as identical < len(terms) and U is not a channel. } // https://go.dev/ref/spec#Core_types // "the type chan E if T contains only bidirectional channels, or the type chan<- E or // <-chan E depending on the direction of the directional channels present." for chans := identical; chans < len(terms); chans++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 5.3K bytes - Viewed (0) -
src/cmd/compile/internal/syntax/testdata/map2.go
var zerok K var zerov V return zerok, zerov, false } return keyval.key, keyval.val, true } // chans func chans_Ranger[T any]() (*chans_Sender[T], *chans_Receiver[T]) // A sender is used to send values to a Receiver. type chans_Sender[T any] struct { values chan<- T done <-chan bool } func (s *chans_Sender[T]) Send(v T) bool { select { case s.values <- v: return true
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 01 12:49:49 UTC 2023 - 3.4K bytes - Viewed (0)