Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 786 for Await (0.04 sec)

  1. platforms/core-configuration/kotlin-dsl/src/main/kotlin/org/gradle/kotlin/dsl/concurrent/future.kt

        override fun isDone(): Boolean = result != null
    
        override fun get(): T {
            outcomeLatch.await()
            return getOrThrow()
        }
    
        override fun get(timeout: Long, unit: TimeUnit): T =
            if (outcomeLatch.await(timeout, unit)) getOrThrow()
            else throw TimeoutException()
    
        private
        fun getOrThrow() = (result as Result<T>).getOrThrow()
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Aug 02 08:06:49 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  2. platforms/extensibility/unit-test-fixtures/src/integTest/groovy/org/gradle/testfixtures/ProjectBuilderIntegrationTest.groovy

            def threads = 5
            def startSignal = new CountDownLatch(1)
            def doneSignal = new CountDownLatch(threads)
    
            when:
            threads.times {
                new Thread({
                    startSignal.await()
                    def spawnedProject = ProjectBuilder.builder().build()
                    try {
                        doneSignal.countDown()
                    } finally {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 13 21:54:27 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  3. platforms/core-execution/workers/src/integTest/groovy/org/gradle/workers/internal/WorkQueueIntegrationTest.groovy

                        def workQueue2 = submit(ParallelWorkAction.class, [ "item3" ])
    
                        signal("submitted")
    
                        workQueue1.await()
    
                        signal("finished")
                    }
                }
            """
    
            def started = blockingHttpServer.expectConcurrentAndBlock("item1", "item2", "item3", "submitted")
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:36:27 UTC 2023
    - 8.7K bytes
    - Viewed (0)
  4. docs/de/docs/advanced/async-tests.md

    ```Python hl_lines="9-10"
    {!../../../docs_src/async_tests/test_main.py!}
    ```
    
    Das ist das Äquivalent zu:
    
    ```Python
    response = client.get('/')
    ```
    
    ... welches wir verwendet haben, um unsere Requests mit dem `TestClient` zu machen.
    
    !!! tip "Tipp"
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Sat Mar 30 20:25:57 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  5. docs/en/docs/advanced/async-tests.md

    Then we can create an `AsyncClient` with the app, and send async requests to it, using `await`.
    
    ```Python hl_lines="9-10"
    {!../../../docs_src/async_tests/test_main.py!}
    ```
    
    This is the equivalent to:
    
    ```Python
    response = client.get('/')
    ```
    
    ...that we used to make our requests with the `TestClient`.
    
    !!! tip
        Note that we're using async/await with the new `AsyncClient` - the request is asynchronous.
    
    !!! warning
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Sat Jan 13 12:07:15 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  6. docs/zh/docs/tutorial/request-files.md

    * `read(size)`:按指定数量的字节或字符(`size` (`int`))读取文件内容;
    * `seek(offset)`:移动至文件 `offset` (`int`)字节处的位置;
        * 例如,`await myfile.seek(0) ` 移动到文件开头;
        * 执行 `await myfile.read()` 后,需再次读取已读取内容时,这种方法特别好用;
    * `close()`:关闭文件。
    
    因为上述方法都是 `async` 方法,要搭配「await」使用。
    
    例如,在 `async` *路径操作函数* 内,要用以下方式读取文件内容:
    
    ```Python
    contents = await myfile.read()
    ```
    
    在普通 `def` *路径操作函数*  内,则可以直接访问 `UploadFile.file`,例如:
    
    ```Python
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Wed Mar 13 19:02:19 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  7. platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/resources/SharedResourceLeaseRegistryTest.groovy

                        assert lockIsHeld(sharedResourceLock)
                        coordinationService.withStateLock(unlock(sharedResourceLock))
                    }
                }
                started.await()
                instant.releaseAll
            }
    
            then:
            noExceptionThrown()
        }
    
        def "locks on different shared resources can be concurrently held"() {
            given:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 08:48:02 UTC 2023
    - 5K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt

          throw RuntimeException("boom!")
        }
    
        queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(200)) {
          log.put("normal task running")
          return@schedule -1L
        }
    
        queue.idleLatch().await(500, TimeUnit.MILLISECONDS)
    
        assertThat(log.take()).isEqualTo("failing task running")
        assertThat(log.take()).isEqualTo("uncaught exception: java.lang.RuntimeException: boom!")
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  9. platforms/extensibility/test-kit/src/integTest/groovy/org/gradle/testkit/runner/GradleRunnerResultIntegrationTest.groovy

                    doLast {
                      startLatch.countDown() // allow b to finish
                      stopLatch.await() // wait for d to start
                    }
                  }
                }
    
                project(":b") {
                  task t {
                    doLast {
                      startLatch.await() // wait for a to start
                    }
                  }
                }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Nov 16 22:36:52 UTC 2023
    - 4.5K bytes
    - Viewed (0)
  10. platforms/core-runtime/messaging/src/integTest/groovy/org/gradle/internal/remote/UnicastMessagingIntegrationTest.groovy

                client.connection.connect()
                client.outgoingService1.doStuff("from client 1")
                client.outgoingService1.doStuff("from client 2")
            }
            received.await()
            client.stop()
            server.stop()
    
            then:
            1 * serverService.doStuff("from client 1")
            1 * serverService.doStuff("from client 2") >> { received.countDown() }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 27 09:21:43 UTC 2024
    - 8.9K bytes
    - Viewed (0)
Back to top