- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 536 for waitc (0.15 sec)
-
src/sync/waitgroup.go
package sync import ( "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. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 4K bytes - Viewed (0) -
src/math/cmplx/tan.go
} return complex(math.Sinh(2*real(x))/d, math.Sin(2*imag(x))/d) } // reducePi reduces the input argument x to the range (-Pi/2, Pi/2]. // x must be greater than or equal to 0. For small arguments it // uses Cody-Waite reduction in 3 float64 parts based on: // "Elementary Function Evaluation: Algorithms and Implementation" // Jean-Michel Muller, 1997. // For very large arguments it uses Payne-Hanek range reduction based on:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 01 03:16:37 UTC 2020 - 8.5K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/ConditionalExecutionQueue.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 1.5K bytes - Viewed (0) -
pkg/util/async/runner.go
limitations under the License. */ package async import ( "sync" ) // Runner is an abstraction to make it easy to start and stop groups of things that can be // described by a single function which waits on a channel close to exit. type Runner struct { lock sync.Mutex loopFuncs []func(stop chan struct{}) stop *chan struct{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 29 06:37:00 UTC 2016 - 1.4K bytes - Viewed (0) -
pkg/test/kube/util.go
gracePeriod := int64(0) return metav1.DeleteOptions{ PropagationPolicy: &propagationPolicy, GracePeriodSeconds: &gracePeriod, } } // WaitUntilPodsAreReady waits until the pod with the name/namespace is in ready state. func WaitUntilPodsAreReady(fetchFunc PodFetchFunc, opts ...retry.Option) ([]corev1.Pod, error) { var pods []corev1.Pod err := retry.UntilSuccess(func() error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Dec 04 22:47:52 UTC 2023 - 9.4K bytes - Viewed (0) -
src/net/http/transport_dial_test.go
<-rt.done if rt.err != nil { return } rt.reqBody.Close() io.ReadAll(rt.res.Body) rt.res.Body.Close() rt.t.Logf("RoundTrip %v: closed request body", rt.roundTripID) } // wantDial waits for the Transport to start a Dial. func (dt *transportDialTester) wantDial() *transportDialTesterConn { c := <-dt.dials c.connID = dt.dialCount dt.dialCount++ dt.t.Logf("Dial %v: started", c.connID) return c
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 17 21:11:57 UTC 2024 - 6.3K bytes - Viewed (0) -
cluster/images/etcd/migrate/migrate_server.go
func NewEtcdMigrateServer(cfg *EtcdMigrateCfg, client EtcdMigrateClient) *EtcdMigrateServer { return &EtcdMigrateServer{cfg: cfg, client: client} } // Start starts an etcd server as a separate process, waits until it has started, and returns a exec.Cmd. // TODO: Add support for listening to client via TLS. func (r *EtcdMigrateServer) Start(version *EtcdVersion) error { etcdCmd := exec.Command(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 30 16:29:59 UTC 2022 - 3.8K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/operations/BuildOperationQueue.java
*/ void add(T operation); /** * Cancels all queued operations in this queue. Any operations that have started will be allowed to complete. */ void cancel(); /** * Waits for all previously added operations to complete. * <p> * On failure, some effort is made to cancel any operations that have not started. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 2.1K bytes - Viewed (0) -
cni/pkg/install/cniconfig.go
} installLog.Infof("Created CNI config %s", cniConfigFilepath) installLog.Debugf("CNI config: %s", pluginConfig) return cniConfigFilepath, nil } // If configured as chained CNI plugin, waits indefinitely for a main CNI config file to exist before returning // Or until cancelled by parent context func getCNIConfigFilepath(ctx context.Context, cniConfName, mountedCNINetDir string, chained bool) (string, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 21 18:32:01 UTC 2024 - 8.3K bytes - Viewed (0) -
pkg/kubelet/runtimeclass/testing/fake_manager.go
return fake.NewSimpleClientset( NewRuntimeClass(EmptyRuntimeClass, ""), NewRuntimeClass(SandboxRuntimeClass, SandboxRuntimeHandler), ) } // StartManagerSync starts the manager, and waits for the informer cache to sync. // Returns a function to stop the manager, which should be called with a defer: // // defer StartManagerSync(t, m)() func StartManagerSync(m *runtimeclass.Manager) func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 2.1K bytes - Viewed (0)