Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 935 for goroutines (0.23 sec)

  1. src/cmd/trace/goroutines.go

    			ExecTimePercent     string
    			MaxTotal            time.Duration
    			Goroutines          []goroutine
    			NonOverlappingStats []string
    			RangeStats          []string
    		}{
    			Name:                name,
    			N:                   len(goroutines),
    			ExecTimePercent:     execTimePercent,
    			MaxTotal:            maxTotalTime,
    			Goroutines:          goroutines,
    			NonOverlappingStats: allNonOverlappingStats,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  2. test/chan/goroutines.go

    // run
    
    // Copyright 2009 The Go Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    // Torture test for goroutines.
    // Make a lot of goroutines, threaded together, and tear them down cleanly.
    
    package main
    
    import (
    	"os"
    	"strconv"
    )
    
    func f(left, right chan int) {
    	left <- <-right
    }
    
    func main() {
    	var n = 10000
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sun Feb 19 06:44:02 UTC 2012
    - 743 bytes
    - Viewed (0)
  3. src/runtime/testdata/testprog/traceback_ancestors.go

    		if !main {
    			ignoreGoroutines[goroutineID()] = true
    		}
    
    		// Start the next goroutine now that there are no more recursions left
    		// for this current goroutine.
    		go recurseThenCallGo(w, frames-1, numFrames, false)
    		return
    	}
    	recurseThenCallGo(w, frames, goroutines-1, main)
    }
    
    func goroutineID() string {
    	buf := make([]byte, 128)
    	runtime.Stack(buf, false)
    	prefix := []byte("goroutine ")
    	var found bool
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Sep 27 17:14:59 UTC 2022
    - 2.1K bytes
    - Viewed (0)
  4. src/cmd/trace/jsontrace.go

    	mode      traceviewer.Mode
    	startTime time.Duration
    	endTime   time.Duration
    
    	// Used if mode != 0.
    	focusGoroutine trace.GoID
    	goroutines     map[trace.GoID]struct{} // Goroutines to be displayed for goroutine-oriented or task-oriented view. goroutines[0] is the main goroutine.
    	tasks          []*trace.UserTaskSummary
    }
    
    // setTask sets a task to focus on.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  5. tests/util/leak/check.go

    	if err != nil {
    		t.Errorf("failed to fetch pre-test goroutines: %v", err)
    		return
    	}
    	existing := map[uint64]struct{}{}
    	for _, g := range existingRaw {
    		existing[g.id] = struct{}{}
    	}
    	filter := func(in []*goroutine) []*goroutine {
    		res := make([]*goroutine, 0, len(in))
    		for _, i := range in {
    			if _, f := existing[i.id]; !f {
    				// This was not in the goroutines list when the test started
    				res = append(res, i)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Dec 20 10:22:38 UTC 2023
    - 6.9K bytes
    - Viewed (0)
  6. src/cmd/vendor/golang.org/x/sync/errgroup/errgroup.go

    		}
    	}()
    	return true
    }
    
    // SetLimit limits the number of active goroutines in this group to at most n.
    // A negative value indicates no limit.
    //
    // Any subsequent call to the Go method will block until it can add an active
    // goroutine without exceeding the configured limit.
    //
    // The limit must not be modified while any goroutines in the group are active.
    func (g *Group) SetLimit(n int) {
    	if n < 0 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 04 17:57:25 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  7. src/internal/trace/summary_test.go

    				}
    			}
    		}
    
    		// Check goroutines.
    		if len(want.goroutines) != len(summary.Goroutines) {
    			t.Errorf("wanted %d goroutines for task %d, got %d goroutines instead", len(want.goroutines), id, len(summary.Goroutines))
    		} else {
    			for _, goid := range want.goroutines {
    				g, ok := summary.Goroutines[goid]
    				if !ok {
    					t.Errorf("want goroutine %d for task %d, not found", goid, id)
    					continue
    				}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  8. src/math/rand/default_test.go

    		// Call Seed and Uint64 concurrently.
    		wg.Add(goroutines)
    		for i := 0; i < goroutines; i++ {
    			go func(s int64) {
    				defer wg.Done()
    				Seed(s)
    			}(int64(i) + 100)
    		}
    		wg.Add(goroutines)
    		for i := 0; i < goroutines; i++ {
    			go func() {
    				defer wg.Done()
    				ch <- Uint64()
    			}()
    		}
    	case 1:
    		// Call Uint64 concurrently with no Seed.
    		wg.Add(goroutines)
    		for i := 0; i < goroutines; i++ {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 07 23:39:35 UTC 2023
    - 3.4K bytes
    - Viewed (0)
  9. src/runtime/proc_test.go

    			// receiver will be blocking when the send occurs when
    			// the goroutines execute in parallel.)
    			//
    			// In each iteration of the benchmark, each goroutine
    			// acts once as sender and once as receiver, so each
    			// goroutine spins for delay twice.
    			//
    			// BenchmarkWakeupParallel is used to estimate how
    			// efficiently the scheduler parallelizes goroutines in
    			// the presence of blocking:
    			//
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jun 14 00:03:57 UTC 2023
    - 25.8K bytes
    - Viewed (0)
  10. src/internal/trace/testdata/testprog/stress.go

    // Tests a many interesting cases (network, syscalls, a little GC, busy goroutines,
    // blocked goroutines, LockOSThread, pipes, and GOMAXPROCS).
    
    //go:build ignore
    
    package main
    
    import (
    	"log"
    	"net"
    	"os"
    	"runtime"
    	"runtime/trace"
    	"sync"
    	"time"
    )
    
    func main() {
    	var wg sync.WaitGroup
    	done := make(chan bool)
    
    	// Create a goroutine blocked before tracing.
    	wg.Add(1)
    	go func() {
    		<-done
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 2.5K bytes
    - Viewed (0)
Back to top