- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 587 for blocked (0.25 sec)
-
src/internal/trace/testdata/testprog/stress-start-stop.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // Tests a many interesting cases (network, syscalls, a little GC, busy goroutines, // blocked goroutines, LockOSThread, pipes, and GOMAXPROCS). //go:build ignore package main import ( "bytes" "io" "log" "net" "os" "runtime" "runtime/trace" "sync" "time" )
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.7K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_controller_test.go
time.Sleep(1 * time.Second) err = expectSyncNotBlocked(fakeDiscoveryClient, &qc.workerLock) if err != nil { t.Fatalf("Expected quotacontroller.Sync to be running but it is blocked: %v", err) } assertMonitors(t, qc, "pods", "deployments") // Simulate the discovery client returning an error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 16:29:33 UTC 2023 - 42.6K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/stacks.go
// 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 var c chan int c <- 0 }() go func() { // func3
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.4K bytes - Viewed (0) -
src/internal/trace/trace_test.go
// of entered -> blocked -> runnable -> running. If in the running state // we block, then we have a futile wakeup. Because of the runtime.Gosched // on these specially marked goroutines, we should end up back in runnable // first. If at any point we go to a different state, switch back to entered // and wait for the next time the goroutine blocks. if ev.Kind() != trace.EventStateTransition {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 18.5K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/SendPartialResponseThenBlock.java
} } @Override public void release() { lock.lock(); try { if (!requestStarted) { throw new IllegalStateException("Response is not blocked, should call waitUntilBlocked() first."); } released = true; condition.signalAll(); } finally { lock.unlock(); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
throw new RejectedExecutionException(); } }; final SequentialExecutor executor = new SequentialExecutor(delegate); final ExecutorService blocked = Executors.newCachedThreadPool(); Future<?> first = blocked.submit( new Runnable() { @Override public void run() { executor.execute(Runnables.doNothing()); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 11.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
throw new RejectedExecutionException(); } }; final SequentialExecutor executor = new SequentialExecutor(delegate); final ExecutorService blocked = Executors.newCachedThreadPool(); Future<?> first = blocked.submit( new Runnable() { @Override public void run() { executor.execute(Runnables.doNothing()); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 11.4K bytes - Viewed (0) -
src/syscall/js/func.go
// Other wrapped functions which are triggered during a call from Go to JavaScript // get executed on the same goroutine. // // As a consequence, if one wrapped function blocks, JavaScript's event loop // is blocked until that function returns. Hence, calling any async JavaScript // API, which requires the event loop, like fetch (http.Client), will cause an
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 22 17:47:47 UTC 2023 - 2.9K bytes - Viewed (0) -
src/net/net_test.go
return } err = peer2(c2.(*TCPConn)) c2.Close() errc <- err }() for i := 0; i < 2; i++ { if err := <-errc; err != nil { t.Error(err) } } } // Tests that a blocked Read is interrupted by a concurrent SetReadDeadline // modifying that Conn's read deadline to the past. // See golang.org/cl/30164 which documented this. The net/http package // depends on this.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jan 22 21:04:44 UTC 2024 - 13.3K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/IndexedCache.java
* * A file lock is held until the value has been produced and written to the persistent store, and other processes will be blocked from producing the same value until this process has completed doing so. * * @return The value. */ @Override V get(K key, Function<? super K, ? extends V> producer); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 2.5K bytes - Viewed (0)