- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 8,530 for ctan (0.05 sec)
-
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/internal/types/testdata/fixedbugs/issue47115.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package p type C0 interface{ int } type C1 interface{ chan int } type C2 interface{ chan int | <-chan int } type C3 interface{ chan int | chan float32 } type C4 interface{ chan int | chan<- int } type C5[T any] interface{ ~chan T | chan<- T } func _[T any](ch T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jan 17 19:54:27 UTC 2023 - 840 bytes - Viewed (0) -
src/internal/types/testdata/fixedbugs/issue51229.go
func ch1[P chan<- int]() (_ P) { return } // core(P) == chan<- int (single type, no tilde) func ch2[P ~chan int]() { return } // core(P) == ~chan<- int (tilde) func ch3[P chan E, E any](E) { return } // core(P) == chan<- E (single type, no tilde) func ch4[P chan E | ~chan<- E, E any](E) { return } // core(P) == ~chan<- E (tilde)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jan 17 19:54:27 UTC 2023 - 4.8K bytes - Viewed (0) -
src/go/types/typestring_test.go
// maps dup("map[string]int"), {"map[struct{x, y int}][]byte", "map[struct{x int; y int}][]byte"}, // channels dup("chan<- chan int"), dup("chan<- <-chan int"), dup("<-chan <-chan int"), dup("chan (<-chan int)"), dup("chan<- func()"), dup("<-chan []func() int"), } // types that depend on other type declarations (src in TestTypes) var dependentTestTypes = []testEntry{ // interfaces
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 28 17:58:07 UTC 2023 - 3.9K bytes - Viewed (0) -
pilot/pkg/server/instance.go
components chan task done chan struct{} // requiredTerminations keeps track of tasks that should block instance exit // if they are not stopped. This allows important cleanup tasks to be completed. // Note: this is still best effort; a process can die at any time. requiredTerminations sync.WaitGroup } func (i *instance) Start(stop <-chan struct{}) error { shutdown := func() { close(i.done) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 4.6K bytes - Viewed (0) -
misc/cgo/gmp/fib.go
// license that can be found in the LICENSE file. //go:build ignore // Compute Fibonacci numbers with two goroutines // that pass integers back and forth. No actual // concurrency, just threads and synchronization // and foreign code on multiple pthreads. package main import ( big "." "runtime" ) func fibber(c chan *big.Int, out chan string, n int64) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 10 22:32:35 UTC 2023 - 919 bytes - Viewed (0) -
pkg/queue/delay.go
} for _, o := range opts { o(q) } return q } type delayQueue struct { workers int workerStopped []chan struct{} // incoming enqueue chan *delayTask // outgoing execute chan *delayTask mu sync.Mutex queue *pq } // Push will execute the task as soon as possible func (d *delayQueue) Push(task Task) { d.pushInternal(&delayTask{do: task, runAt: time.Now()})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 06:27:31 UTC 2023 - 6.7K bytes - Viewed (0) -
src/reflect/type_test.go
{"struct{i int; s S}", args{reflect.TypeOf(struct { i int s S }{})}, true}, {"map[int][int]", args{reflect.TypeOf(map[int]int{})}, false}, {"[4]chan int", args{reflect.TypeOf([4]chan int{})}, true}, {"[0]struct{_ S}", args{reflect.TypeOf([0]struct { _ S }{})}, true}, {"struct{i int; _ S}", args{reflect.TypeOf(struct { i int _ S }{})}, false},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 23:39:44 UTC 2024 - 4.2K bytes - Viewed (0) -
pilot/pkg/server/instance_test.go
completed *atomic.Bool d time.Duration stop chan struct{} } func newFakeComponent(d time.Duration, stop chan struct{}) *fakeComponent { return &fakeComponent{ started: atomic.NewBool(false), completed: atomic.NewBool(false), d: d, stop: stop, } } func (c *fakeComponent) Run(stop <-chan struct{}) error { c.started.Store(true) select {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 23:02:39 UTC 2024 - 4.1K bytes - Viewed (0) -
pkg/revisions/default_watcher_test.go
func expectRevisionChan(t test.Failer, revisionChan chan string, expected string) { select { case rev := <-revisionChan: if rev != expected { t.Fatalf("expected revision %q to be produced on chan, got %q", expected, rev) } case <-time.After(time.Second * 5): t.Fatalf("timed out waiting for value on default revision chan") } } func TestNoDefaultRevision(t *testing.T) { stop := make(chan struct{}) client := kube.NewFakeClient()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 23 17:46:59 UTC 2023 - 3.2K bytes - Viewed (0)