Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 441 for goroutines (0.13 sec)

  1. src/cmd/vendor/golang.org/x/tools/go/analysis/passes/testinggoroutine/doc.go

    // Fatal from a test goroutine.
    //
    // # Analyzer testinggoroutine
    //
    // testinggoroutine: report calls to (*testing.T).Fatal from goroutines started by a test
    //
    // Functions that abruptly terminate a test, such as the Fatal, Fatalf, FailNow, and
    // Skip{,f,Now} methods of *testing.T, must be called from the test goroutine itself.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Nov 29 21:28:33 UTC 2023
    - 853 bytes
    - Viewed (0)
  2. src/internal/chacha8rand/chacha8.go

    func block(seed *[4]uint64, blocks *[32]uint64, counter uint32)
    
    // A State holds the state for a single random generator.
    // It must be used from one goroutine at a time.
    // If used by multiple goroutines at a time, the goroutines
    // may see the same random values, but the code will not
    // crash or cause out-of-bounds memory accesses.
    type State struct {
    	buf  [32]uint64
    	seed [4]uint64
    	i    uint32
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 13 21:47:29 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  3. src/internal/trace/testdata/testprog/stacks.go

    	}
    	defer trace.Stop() // in case of early return
    
    	// Now we will do a bunch of things for which we verify stacks later.
    	// It is impossible to ensure that a goroutine has actually blocked
    	// on a channel, in a select or otherwise. So we kick off goroutines
    	// that need to block first in the hope that while we are executing
    	// the rest of the test, they will block.
    	go func() { // func1
    		select {}
    	}()
    	go func() { // func2
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  4. src/sync/atomic/example_test.go

    }
    
    func requests() chan int {
    	return make(chan int)
    }
    
    // The following example shows how to use Value for periodic program config updates
    // and propagation of the changes to worker goroutines.
    func ExampleValue_config() {
    	var config atomic.Value // holds current server configuration
    	// Create initial config value and store into config.
    	config.Store(loadConfig())
    	go func() {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Apr 18 23:58:54 UTC 2018
    - 2.2K bytes
    - Viewed (0)
  5. src/internal/singleflight/singleflight_test.go

    		panic("third must not be started")
    	})
    
    	if g.ForgetUnshared(key) {
    		t.Errorf("Before first goroutine finished, key %q is shared, should return false", key)
    	}
    
    	close(firstCh)
    	firstFinished.Wait()
    
    	if g.ForgetUnshared(key) {
    		t.Errorf("After first goroutine finished, key %q is still shared, should return false", key)
    	}
    
    	secondCh <- struct{}{}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Mar 29 22:21:50 UTC 2023
    - 3.9K bytes
    - Viewed (0)
  6. pkg/util/goroutinemap/goroutinemap.go

    )
    
    // GoRoutineMap defines a type that can run named goroutines and track their
    // state.  It prevents the creation of multiple goroutines with the same name
    // and may prevent recreation of a goroutine until after the a backoff time
    // has elapsed after the last goroutine with that name finished.
    type GoRoutineMap interface {
    	// Run adds operation name to the list of running operations and spawns a
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 16 11:54:27 UTC 2020
    - 6.8K bytes
    - Viewed (0)
  7. doc/next/6-stdlib/99-minor/runtime/debug/42888.md

    file to which the runtime should write its fatal crash report.
    It may be used to construct an automated reporting mechanism for all
    unexpected crashes, not just those in goroutines that explicitly use
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 20:49:22 UTC 2024
    - 282 bytes
    - Viewed (0)
  8. src/runtime/pprof/runtime.go

    // runtime_getProfLabel is defined in runtime/proflabel.go.
    func runtime_getProfLabel() unsafe.Pointer
    
    // SetGoroutineLabels sets the current goroutine's labels to match ctx.
    // A new goroutine inherits the labels of the goroutine that created it.
    // This is a lower-level API than [Do], which should be used instead when possible.
    func SetGoroutineLabels(ctx context.Context) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Nov 08 16:59:11 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  9. internal/http/server.go

    			if atomic.LoadInt32(&srv.requestCount) <= 0 {
    				return nil
    			}
    
    			// Write all running goroutines.
    			tmp, err := os.CreateTemp("", "minio-goroutines-*.txt")
    			if err == nil {
    				_ = pprof.Lookup("goroutine").WriteTo(tmp, 1)
    				tmp.Close()
    				return errors.New("timed out. some connections are still active. goroutines written to " + tmp.Name())
    			}
    			return errors.New("timed out. some connections are still active")
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Feb 09 21:25:16 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  10. src/internal/trace/testdata/generators/go122-go-create-without-running-g.go

    // the time of writing, one such example is goroutines created by expiring
    // timers.
    
    package main
    
    import (
    	"internal/trace"
    	"internal/trace/event/go122"
    	testgen "internal/trace/internal/testgen/go122"
    )
    
    func main() {
    	testgen.Main(gen)
    }
    
    func gen(t *testgen.Trace) {
    	g1 := t.Generation(1)
    
    	// A goroutine gets created on a running P, then starts running.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 21:15:28 UTC 2024
    - 996 bytes
    - Viewed (0)
Back to top