Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 62 for goroutines (0.16 sec)

  1. src/runtime/mprof.go

    //
    // Some goroutines (the finalizer goroutine, which at various times can be
    // either a "system" or a "user" goroutine, and the goroutine that is
    // coordinating the profile, any goroutines created during the profile) move
    // directly to the "Satisfied" state.
    type goroutineProfileState uint32
    
    const (
    	goroutineProfileAbsent goroutineProfileState = iota
    	goroutineProfileInProgress
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:37 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  2. src/runtime/pprof/pprof_test.go

    				for j := 0; j < i; j++ {
    					// Spin for longer and longer as the test goes on. This
    					// goroutine will do O(N^2) work with the number of
    					// goroutines it launches. This should be slow relative to
    					// the work involved in collecting a goroutine profile,
    					// which is O(N) with the high-water mark of the number of
    					// goroutines in this process (in the allgs slice).
    					runtime.Gosched()
    				}
    				if i == 0 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 18:42:28 UTC 2024
    - 68.8K bytes
    - Viewed (0)
  3. src/runtime/mgc.go

    		// N.B. we intentionally wait on each goroutine individually
    		// rather than starting all in a batch and then waiting once
    		// afterwards. By running one goroutine at a time, we can take
    		// advantage of runnext to bounce back and forth between
    		// workers and this goroutine. In an overloaded application,
    		// this can reduce GC start latency by prioritizing these
    		// goroutines rather than waiting on the end of the run queue.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 62K bytes
    - Viewed (0)
  4. src/testing/testing.go

    // by calling runtime.Goexit (which then runs all deferred calls in the
    // current goroutine).
    // Execution will continue at the next test or benchmark.
    // FailNow must be called from the goroutine running the
    // test or benchmark function, not from other goroutines
    // created during the test. Calling FailNow does not stop
    // those other goroutines.
    func (c *common) FailNow() {
    	c.checkFuzzFn("FailNow")
    	c.Fail()
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 76.1K bytes
    - Viewed (0)
  5. src/time/time_test.go

    // and that we also don't panic.
    func TestConcurrentTimerReset(t *testing.T) {
    	const goroutines = 8
    	const tries = 1000
    	var wg sync.WaitGroup
    	wg.Add(goroutines)
    	timer := NewTimer(Hour)
    	for i := 0; i < goroutines; i++ {
    		go func(i int) {
    			defer wg.Done()
    			for j := 0; j < tries; j++ {
    				timer.Reset(Hour + Duration(i*j))
    			}
    		}(i)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:13:47 UTC 2024
    - 56.5K bytes
    - Viewed (0)
  6. src/runtime/mgcmark.go

    			}
    
    			// TODO: suspendG blocks (and spins) until gp
    			// stops, which may take a while for
    			// running goroutines. Consider doing this in
    			// two phases where the first is non-blocking:
    			// we scan the stacks we can and ask running
    			// goroutines to scan themselves; and the
    			// second blocks.
    			stopped := suspendG(gp)
    			if stopped.dead {
    				gp.gcscandone = true
    				return
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 18 21:25:11 UTC 2024
    - 52.5K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go

    		// Each request is sent from a separate goroutine, with a client-side timeout of 1m, on
    		// the other hand, the server enforces a timeout of 5s (via the timeout filter).
    		// The first request should get dispatched immediately; execution (a) starts with closing
    		// the channel that triggers the second client goroutine to send its request and then (b)
    		// waits for both client goroutines to have gotten a response (expected to be timeouts).
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 52.6K bytes
    - Viewed (0)
  8. src/internal/trace/order.go

    		return fmt.Errorf("expected no proc but had one")
    	}
    
    	// Check goroutine requirements.
    	if reqs.Goroutine == event.MustHave && ctx.G == NoGoroutine {
    		return fmt.Errorf("expected a goroutine but didn't have one")
    	} else if reqs.Goroutine == event.MustNotHave && ctx.G != NoGoroutine {
    		return fmt.Errorf("expected no goroutine but had one")
    	}
    	return nil
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 03 14:56:25 UTC 2024
    - 52.4K bytes
    - Viewed (0)
  9. src/runtime/mgcpacer.go

    	// last GC cycle.
    	lastStackScan atomic.Uint64
    
    	// maxStackScan is the amount of allocated goroutine stack space in
    	// use by goroutines.
    	//
    	// This number tracks allocated goroutine stack space rather than used
    	// goroutine stack space (i.e. what is actually scanned) because used
    	// goroutine stack space is much harder to measure cheaply. By using
    	// allocated space, we make an overestimate; this is OK, it's better
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 55.4K bytes
    - Viewed (0)
  10. src/os/os_test.go

    	// Note the deferred Wait must be called after the deferred close(done),
    	// to ensure the N goroutines have been released even if the main goroutine
    	// calls Fatalf. It must be called before the Chdir back to the original
    	// directory, and before the deferred deletion implied by TempDir,
    	// so as not to interfere while the N goroutines are still running.
    	defer wg.Wait()
    	defer close(done)
    
    	for i := 0; i < N; i++ {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 83.1K bytes
    - Viewed (0)
Back to top