- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 2,355 for nwait (0.04 sec)
-
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
functionBlocking.await(); return immediateFuture(null); } }); ExecutorService executor = Executors.newSingleThreadExecutor(); try { ListenableFuture<?> output = Futures.transformAsync(immediateFuture(null), function, executor); functionCalled.await(); assertThat(output.toString()).contains(function.toString());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 144.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Oct 03 20:10:02 UTC 2023 - 23.2K bytes - Viewed (0) -
platforms/core-execution/workers/src/integTest/groovy/org/gradle/workers/internal/WorkerExecutorParallelIntegrationTest.groovy
submitWorkItem("workItem1") submitWorkItem("workItem2") if (${waitForResults}) { workerExecutor.await() } } } """ blockingHttpServer.expectConcurrent("workItem0", "workItem1", "workItem2") expect: args("--max-workers=3")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 24 06:54:47 UTC 2023 - 31.7K bytes - Viewed (0) -
docs_src/websockets/tutorial002_an_py310.py
): await websocket.accept() while True: data = await websocket.receive_text() await websocket.send_text( f"Session cookie or query token value is: {cookie_or_token}" ) if q is not None: await websocket.send_text(f"Query parameter q is: {q}")
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Mar 18 12:29:59 UTC 2023 - 2.8K bytes - Viewed (0) -
docs_src/websockets/tutorial002_py310.py
cookie_or_token: str = Depends(get_cookie_or_token), ): await websocket.accept() while True: data = await websocket.receive_text() await websocket.send_text( f"Session cookie or query token value is: {cookie_or_token}" ) if q is not None: await websocket.send_text(f"Query parameter q is: {q}")
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Mar 18 12:29:59 UTC 2023 - 2.7K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret_test.go
- name: 54643f96-eca0-11e9-bb97-42010a80000a user: token: token --- `, clusterNameAnnotationKey, secretName, key) if diff := cmp.Diff(got, wantOutput); diff != "" { tt.Errorf("got\n%v\nwant\n%vdiff %v", got, c.want, diff) } } }) } } func TestGetServiceAccountSecretToken(t *testing.T) { secret := makeSecret("secret", "caData", "token") type tc struct { name string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 20.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/waitgroup/waitgroup.go
defer wg.mu.RUnlock() if wg.wait && delta > 0 { return fmt.Errorf("add with positive delta after Wait is forbidden") } wg.wg.Add(delta) return nil } // Done decrements the WaitGroup counter. func (wg *SafeWaitGroup) Done() { wg.wg.Done() } // Wait blocks until the WaitGroup counter is zero. func (wg *SafeWaitGroup) Wait() { wg.mu.Lock() wg.wait = true wg.mu.Unlock() wg.wg.Wait()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 11 03:04:14 UTC 2018 - 1.5K bytes - Viewed (0) -
docs_src/websockets/tutorial002_an.py
): await websocket.accept() while True: data = await websocket.receive_text() await websocket.send_text( f"Session cookie or query token value is: {cookie_or_token}" ) if q is not None: await websocket.send_text(f"Query parameter q is: {q}")
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Mar 18 12:29:59 UTC 2023 - 2.8K bytes - Viewed (0) -
docs_src/websockets/tutorial002_an_py39.py
): await websocket.accept() while True: data = await websocket.receive_text() await websocket.send_text( f"Session cookie or query token value is: {cookie_or_token}" ) if q is not None: await websocket.send_text(f"Query parameter q is: {q}")
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Mar 18 12:29:59 UTC 2023 - 2.8K bytes - Viewed (0) -
docs/tr/docs/async.md
# Concurrency ve async / await *path operasyon fonksiyonu* için `async def `sözdizimi, asenkron kod, eşzamanlılık ve paralellik hakkında bazı ayrıntılar. ## Aceleniz mi var? <abbr title="too long; didn't read"><strong>TL;DR:</strong></abbr> Eğer `await` ile çağrılması gerektiğini belirten üçüncü taraf kütüphaneleri kullanıyorsanız, örneğin: ```Python results = await some_library() ```
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Apr 18 19:53:19 UTC 2024 - 21.9K bytes - Viewed (0)