- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 42 for waitRead (0.12 sec)
-
guava/src/com/google/common/util/concurrent/DirectExecutorService.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 3.5K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/work/DefaultAsyncWorkTrackerTest.groovy
instant.completeWorker1 } then: instant.waitFinished >= instant.completeWorker1 } def "work can be submitted to one operation while another operation is being waited on"() { def operation1 = Mock(BuildOperationRef) def operation2 = Mock(BuildOperationRef) when: async { workerThread {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 06 04:53:10 UTC 2023 - 14.9K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/work/AsyncWorkTracker.java
* the asynchronous work, a {@link org.gradle.internal.exceptions.MultiCauseException} will be thrown with any exceptions * thrown. * * @param workCompletions - The items of work that should be waited on * @param lockRetention - How project locks should be treated while waiting on work */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 26 11:22:05 UTC 2024 - 3K bytes - Viewed (0) -
cluster/gce/windows/k8s-node-setup.psm1
function WaitFor_KubeletAndKubeProxyReady { $waited = 0 $timeout = 10 while (((Get-Service kube-proxy).Status -ne 'Running' -or (Get-Service kubelet).Status -ne 'Running') -and $waited -lt $timeout) { Start-Sleep 1 $waited++ } # Timeout occurred if ($waited -ge $timeout) { Log-Output "$(Get-Service kube* | Out-String)"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 21:13:22 UTC 2024 - 88.3K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_tensor.cc
if (std::find(streams_defined_on_.begin(), streams_defined_on_.end(), stream) != streams_defined_on_.end()) { // stream is in streams_defined_on_; it doesn't need to be waited on. return; } stream->WaitFor(definition_event_.get()).IgnoreError(); streams_defined_on_.push_back(stream); } void XlaTensor::ResetDefinitionEvent(std::shared_ptr<se::Event> event,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 22 08:47:20 UTC 2024 - 4.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/timer.go
// expected to be safe for calls from multiple goroutines. type Timer interface { // C returns a channel that will receive a struct{} each time the timer fires. // The channel should not be waited on after Stop() is invoked. It is allowed // to cache the returned value of C() for the lifetime of the Timer. C() <-chan time.Time // Next is invoked by wait functions to signal timers that the next interval
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 2.9K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonStopClient.java
} if (connection != null) { throw new GradleException(String.format("Timeout waiting for all daemons to stop. Waited %s.", timer.getElapsed())); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 5.2K bytes - Viewed (0) -
src/os/exec_unix.go
// may wait on the wrong process if the PID is reused after the // completes its wait. // // Checking for statusDone here would not be a complete fix, as the PID // could still be waited on and reused prior to blockUntilWaitable. switch p.pidStatus() { case statusReleased: return nil, syscall.EINVAL } // If we can block until Wait4 will succeed immediately, do so.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 22:06:47 UTC 2024 - 4.1K bytes - Viewed (0) -
src/sync/waitgroup.go
// positive delta that start when the counter is greater than zero, may happen // at any time. // Typically this means the calls to Add should execute before the statement // creating the goroutine or other event to be waited for. // If a WaitGroup is reused to wait for several independent sets of events, // new Add calls must happen after all previous Wait calls have returned. // See the WaitGroup example. func (wg *WaitGroup) Add(delta int) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 4K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_termination_order_test.go
} return delay.(int64) } for _, tc := range []struct { containerName string expectedDelay int64 }{ { containerName: "sc1", // overall grace period limits the amount of time waited here expectedDelay: 2, }, { containerName: "sc2", expectedDelay: 2, }, { containerName: "sc3", expectedDelay: 1, }, { containerName: "main",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 18 00:07:21 UTC 2023 - 6.7K bytes - Viewed (0)