Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 68 for goroutineID (0.28 sec)

  1. src/sync/mutex.go

    	}
    }
    
    // Unlock unlocks m.
    // It is a run-time error if m is not locked on entry to Unlock.
    //
    // A locked [Mutex] is not associated with a particular goroutine.
    // It is allowed for one goroutine to lock a Mutex and then
    // arrange for another goroutine to unlock it.
    func (m *Mutex) Unlock() {
    	if race.Enabled {
    		_ = m.state
    		race.Release(unsafe.Pointer(m))
    	}
    
    	// Fast path: drop lock bit.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  2. src/sync/waitgroup.go

    	"internal/race"
    	"sync/atomic"
    	"unsafe"
    )
    
    // A WaitGroup waits for a collection of goroutines to finish.
    // The main goroutine calls [WaitGroup.Add] to set the number of
    // goroutines to wait for. Then each of the goroutines
    // runs and calls [WaitGroup.Done] when finished. At the same time,
    // [WaitGroup.Wait] can be used to block until all goroutines have finished.
    //
    // A WaitGroup must not be copied after first use.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 4K bytes
    - Viewed (0)
  3. src/sync/cond.go

    	runtime_notifyListWait(&c.notify, t)
    	c.L.Lock()
    }
    
    // Signal wakes one goroutine waiting on c, if there is any.
    //
    // It is allowed but not required for the caller to hold c.L
    // during the call.
    //
    // Signal() does not affect goroutine scheduling priority; if other goroutines
    // are attempting to lock c.L, they may be awoken before a "waiting" goroutine.
    func (c *Cond) Signal() {
    	c.checker.check()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  4. manifests/addons/dashboards/pilot.libsonnet

          panels.timeSeries.base('CPU Usage', queries.cpuUsage, 'CPU usage of each running instance'),
          panels.timeSeries.base('Goroutines', queries.goroutines, 'Goroutine count for each running instance'),
        ]),
      ], panelHeight=10, startY=1)
      + g.util.grid.makeGrid([
        row.new('Push Information')
        + row.withPanels([
          panels.timeSeries.xdsPushes(
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 20:46:28 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  5. src/os/exec/exec.go

    	// goroutines exit, or after WaitDelay has expired.
    	parentIOPipes []io.Closer
    
    	// goroutine holds a set of closures to execute to copy data
    	// to and/or from the command's I/O pipes.
    	goroutine []func() error
    
    	// If goroutineErr is non-nil, it receives the first error from a copying
    	// goroutine once all such goroutines have completed.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 20:13:53 UTC 2024
    - 41.4K bytes
    - Viewed (0)
  6. src/iter/pull_test.go

    	// to Gosched back into itself, so we require NumGoroutine to be
    	// the same 100 times in a row. This should be more than enough to
    	// ensure all goroutines get a chance to run to completion (or to
    	// some block point) for a small group of test goroutines.
    	defer runtime.GOMAXPROCS(runtime.GOMAXPROCS(1))
    
    	c := 0
    	ng := runtime.NumGoroutine()
    	for i := 0; i < 1000; i++ {
    		nng := runtime.NumGoroutine()
    		if nng == ng {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 19:09:28 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  7. src/sync/pool.go

    // Any item stored in the Pool may be removed automatically at any time without
    // notification. If the Pool holds the only reference when this happens, the
    // item might be deallocated.
    //
    // A Pool is safe for use by multiple goroutines simultaneously.
    //
    // Pool's purpose is to cache allocated but unused items for later reuse,
    // relieving pressure on the garbage collector. That is, it makes it easy to
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  8. src/runtime/coro.go

    // a goroutine blocked on it. If another goroutine calls coroswitch(c),
    // the caller becomes the goroutine blocked in c, and the goroutine
    // formerly blocked in c starts running.
    // These switches continue until a call to coroexit(c),
    // which ends the use of the coro by releasing the blocked
    // goroutine in c and exiting the current goroutine.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 19:09:18 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  9. manifests/addons/dashboards/pilot-dashboard.gen.json

                      "uid": "$datasource"
                   },
                   "expr": "sum by (pod) (\n  go_goroutines{app=\"istiod\"}\n)",
                   "legendFormat": "Goroutines ({{pod}})"
                }
             ],
             "title": "Goroutines",
             "type": "timeseries"
          },
          {
             "collapsed": false,
             "gridPos": {
                "h": 1,
                "w": 24,
                "x": 0,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 20:46:28 UTC 2024
    - 23.5K bytes
    - Viewed (0)
  10. src/net/http/transport.go

    			}
    			return false
    		}
    		if trace != nil && trace.PutIdleConn != nil {
    			trace.PutIdleConn(nil)
    		}
    		return true
    	}
    
    	// eofc is used to block caller goroutines reading from Response.Body
    	// at EOF until this goroutines has (potentially) added the connection
    	// back to the idle pool.
    	eofc := make(chan struct{})
    	defer close(eofc) // unblock reader on errors
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 91K bytes
    - Viewed (0)
Back to top