Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 2,669 for done2 (0.1 sec)

  1. test/fixedbugs/issue11256.go

    			// Exit without unwinding stack barriers.
    			runtime.Goexit()
    		}()
    
    		// Generate some garbage.
    		x[i] = make([]byte, 1024*1024)
    
    		// Give GC some time to install stack barriers in the G.
    		time.Sleep(50 * time.Microsecond)
    		atomic.StoreInt32(&done, 1)
    		for atomic.LoadInt32(&done) == 1 {
    			runtime.Gosched()
    		}
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 29 15:02:30 UTC 2015
    - 1.1K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. src/sync/cond_test.go

    			c.L.Lock()
    		}
    		c.L.Unlock()
    		done <- true
    	}()
    	go func() {
    		c.L.Lock()
    		for {
    			if x == 2 {
    				c.Wait()
    				if x != 3 {
    					t.Error("want 3")
    				}
    				break
    			}
    			if x == 3 {
    				break
    			}
    			c.L.Unlock()
    			runtime.Gosched()
    			c.L.Lock()
    		}
    		c.L.Unlock()
    		done <- true
    	}()
    	<-done
    	<-done
    	<-done
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Mar 22 18:52:42 UTC 2023
    - 5K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. tools/gen_istio_image_list.sh

            hubs=()
            images=()
            tags=()
    
            for hub in ${HUB}; do
              hubs+=( "$hub" );
            done
    
            for img in ${IMAGE}; do
              images+=( "$img" );
            done
    
            for tag in ${TAG}; do
              tags+=( "$tag" );
            done
    
            for i in "${!hubs[@]}"; do
              if [ -z "${images[$i]}" ]
              then
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jul 25 04:04:35 UTC 2023
    - 4.5K bytes
    - Viewed (0)
  9. 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)
  10. test/typeparam/chansimp.dir/a.go

    	d := make(chan struct{})
    	s := &Sender[Elem]{
    		values: c,
    		done:   d,
    	}
    	r := &Receiver[Elem]{
    		values: c,
    		done:   d,
    	}
    	runtime.SetFinalizer(r, (*Receiver[Elem]).finalize)
    	return s, r
    }
    
    // A Sender is used to send values to a Receiver.
    type Sender[Elem any] struct {
    	values chan<- Elem
    	done   <-chan struct{}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jul 28 21:40:40 UTC 2021
    - 5.5K bytes
    - Viewed (0)
Back to top