Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 628 for kuwait (0.1 sec)

  1. guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        public @Nullable Void call() throws InterruptedException {
          running = true;
          startLatch.countDown();
          stopLatch.await();
          running = false;
          return null;
        }
    
        public void waitForStart() throws InterruptedException {
          startLatch.await();
        }
    
        public void stop() {
          stopLatch.countDown();
        }
    
        public boolean isRunning() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/helper/ProcessHelper.java

                    }
                }, "ProcessCloser-output-" + sessionId).start();
    
                try {
                    latch.await(10, TimeUnit.SECONDS);
                } catch (final InterruptedException e) {
                    logger.warn("Interrupted to wait a process.", e);
                }
                try {
                    process.destroyForcibly().waitFor(processDestroyTimeout, TimeUnit.SECONDS);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/cache/CacheBuilderTest.java

                  }
                })
            .start();
    
        // wait for the computingEntry to be created
        computationStarted.await();
        cache.invalidateAll();
        // let the computation proceed
        computingLatch.countDown();
        // don't check cache.size() until we know the get("b") call is complete
        computationComplete.await();
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 15:00:32 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

        afterStarted.countDown();
        // We do not call awaitHealthy because, due to races, that method may throw an exception.  But
        // we really just want to wait for the thread to be in the failure callback so we wait for that
        // explicitly instead.
        failEnter.await();
        assertFalse("State should be updated before calling listeners", manager.isHealthy());
        // now we want to stop the services.
        Thread stoppingThread =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  5. docs_src/websockets/tutorial003_py39.py

                await connection.send_text(message)
    
    
    manager = ConnectionManager()
    
    
    @app.get("/")
    async def get():
        return HTMLResponse(html)
    
    
    @app.websocket("/ws/{client_id}")
    async def websocket_endpoint(websocket: WebSocket, client_id: int):
        await manager.connect(websocket)
        try:
            while True:
                data = await websocket.receive_text()
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Mar 18 12:29:59 UTC 2023
    - 2.5K bytes
    - Viewed (0)
  6. tests/test_ws_router.py

        await websocket.accept()
        await websocket.send_text(pathparam)
        await websocket.send_text(queryparam)
        await websocket.close()
    
    
    async def ws_dependency():
        return "Socket Dependency"
    
    
    @router.websocket("/router-ws-depends/")
    async def router_ws_decorator_depends(
        websocket: WebSocket, data=Depends(ws_dependency)
    ):
        await websocket.accept()
        await websocket.send_text(data)
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Jun 11 19:08:14 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  7. tests/test_datastructures.py

        stream = io.BytesIO(b"data")
        file = UploadFile(filename="file", file=stream, size=4)
        assert await file.read() == b"data"
        assert file.size == 4
        await file.write(b" and more data!")
        assert await file.read() == b""
        assert file.size == 19
        await file.seek(0)
        assert await file.read() == b"data and more data!"
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Oct 18 12:36:40 UTC 2023
    - 2K bytes
    - Viewed (0)
  8. tests/test_ws_dependencies.py

    async def index(websocket: WebSocket, deps: DepList):
        await websocket.accept()
        await websocket.send_text(json.dumps(deps))
        await websocket.close()
    
    
    @router.websocket("/router", dependencies=[create_dependency("routerindex")])
    async def routerindex(websocket: WebSocket, deps: DepList):
        await websocket.accept()
        await websocket.send_text(json.dumps(deps))
        await websocket.close()
    
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Jun 11 20:35:39 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  9. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt

        val entryTime = System.nanoTime()
    
        for (queue in TaskRunner.INSTANCE.activeQueues()) {
          // We wait at most 1 second, so we don't ever turn multiple lost threads into
          // a test timeout failure.
          val waitTime = (entryTime + 1_000_000_000L - System.nanoTime())
          if (!queue.idleLatch().await(waitTime, TimeUnit.NANOSECONDS)) {
            TaskRunner.INSTANCE.lock.withLock {
              TaskRunner.INSTANCE.cancelAll()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  10. 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: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 21.9K bytes
    - Viewed (0)
Back to top