- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 2,669 for done2 (0.1 sec)
-
test/fixedbugs/issue11256.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 29 15:02:30 UTC 2015 - 1.1K bytes - Viewed (0) -
pkg/lazy/lazy.go
if atomic.LoadUint32(&l.done) == 0 { // Outlined slow-path to allow inlining of the fast-path. return l.doSlow() } return l.res, l.err } func (l *lazyImpl[T]) doSlow() (T, error) { l.m.Lock() defer l.m.Unlock() if l.done == 0 { done := uint32(1) // Defer in case of panic defer func() { atomic.StoreUint32(&l.done, done) }() res, err := l.getter()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 17 22:54:10 UTC 2022 - 2.2K bytes - Viewed (0) -
test/fixedbugs/issue16331.go
} func F(args []reflect.Value) (results []reflect.Value) { return nil } func main() { done := make(chan bool) go func() { // Test reflect.makeFuncStub. t := reflect.TypeOf((func())(nil)) f := reflect.MakeFunc(t, F).Interface().(func()) defer f() growstack(10000) done <- true }() <-done go func() { // Test reflect.methodValueCall. f := reflect.ValueOf(T{}).Method(0).Interface().(func())
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 17 18:57:01 UTC 2016 - 839 bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller_test.go
wg.Add(1) go func() { defer wg.Done() informer.Run(testContext.Done()) }() // Start controller wg.Add(1) go func() { defer wg.Done() stopReason := myController.Run(testContext) require.ErrorIs(t, stopReason, context.Canceled) }() // Wait for controller and informer to start up require.True(t, cache.WaitForCacheSync(testContext.Done(), myController.HasSynced))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 16.1K bytes - Viewed (0) -
src/sync/cond_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 22 18:52:42 UTC 2023 - 5K bytes - Viewed (0) -
pkg/apis/storage/validation/validation_test.go
Key: "failure-domain.beta.kubernetes.io/zone", Values: []string{"zone1", "zone2"}, }}, }, { MatchLabelExpressions: []api.TopologySelectorLabelRequirement{{ Key: "failure-domain.beta.kubernetes.io/zone", Values: []string{"zone2", "zone1"}, }}, }} cases := map[string]bindingTest{ "no topology": { class: makeClass(&waitingMode, nil),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 69.7K 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) -
tools/gen_istio_image_list.sh
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jul 25 04:04:35 UTC 2023 - 4.5K bytes - Viewed (0) -
test/fixedbugs/issue53600.out
9223372036854775807 false done 9223372036854775806 false 9223372036854775807 false done 9223372036854775805 false 9223372036854775807 false done
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jul 06 17:00:37 UTC 2022 - 165 bytes - Viewed (0) -
test/typeparam/chansimp.dir/a.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jul 28 21:40:40 UTC 2021 - 5.5K bytes - Viewed (0)