Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 125 for park (0.08 sec)

  1. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

             * protect ourselves from this, we park ourselves and tell our interrupter that we did so.
             */
            if (state == PARKED || compareAndSet(state, PARKED)) {
              // Interrupting Cow Says:
              //  ______
              // < Park >
              //  ------
              //        \   ^__^
              //         \  (oo)\_______
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 10K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

          currentWaiter.unpark();
        }
      }
    
      // Gets and Timed Gets
      //
      // * Be responsive to interruption
      // * Don't create Waiter nodes if you aren't going to park, this helps reduce contention on
      //   waitersField.
      // * Future completion is defined by when #valueField becomes non-null/non DelegatingToFuture
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 33.2K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/AbstractFutureState.java

          currentWaiter.unpark();
        }
      }
    
      // Gets and Timed Gets
      //
      // * Be responsive to interruption
      // * Don't create Waiter nodes if you aren't going to park, this helps reduce contention on
      //   waitersField.
      // * Future completion is defined by when #valueField becomes non-null/non DelegatingToFuture
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  4. samples/guide/src/main/java/okhttp3/recipes/kt/PostForm.kt

    import okhttp3.OkHttpClient
    import okhttp3.Request
    
    class PostForm {
      private val client = OkHttpClient()
    
      fun run() {
        val formBody =
          FormBody
            .Builder()
            .add("search", "Jurassic Park")
            .build()
        val request =
          Request(
            url = "https://en.wikipedia.org/w/index.php".toHttpUrl(),
            body = formBody,
          )
    
        client.newCall(request).execute().use { response ->
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 1.3K bytes
    - Viewed (0)
  5. okhttp-tls/src/test/java/okhttp3/tls/internal/der/DerCertificatesTest.kt

          ),
        )
      }
    
      @Test
      fun `certificate attributes`() {
        val certificate =
          HeldCertificate
            .Builder()
            .certificateAuthority(3)
            .commonName("Jurassic Park")
            .organizationalUnit("Gene Research")
            .addSubjectAlternativeName("*.example.com")
            .addSubjectAlternativeName("www.example.org")
            .validityInterval(-1000L, 2000L)
            .serialNumber(17L)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 43.9K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        Thread.class.getMethod("resume").invoke(thread);
        thread.join();
        // It's possible to race and suspend the thread just before the park call actually takes effect,
        // causing the thread to be suspended for 3.5 seconds, and then park itself for 2 seconds after
        // being resumed. To avoid a flake in this scenario, calculate how long that thread actually
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 46.8K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        Thread.class.getMethod("resume").invoke(thread);
        thread.join();
        // It's possible to race and suspend the thread just before the park call actually takes effect,
        // causing the thread to be suspended for 3.5 seconds, and then park itself for 2 seconds after
        // being resumed. To avoid a flake in this scenario, calculate how long that thread actually
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 46.8K bytes
    - Viewed (0)
  8. docs/recipes.md

    `MultipartBody.Builder` can build sophisticated request bodies compatible with HTML file upload forms. Each part of a multipart request body is itself a request body, and can define its own headers. If present, these headers should describe the part body, such as its `Content-Disposition`. The `Content-Length` and `Content-Type` headers are added automatically if they're available.
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 17:01:12 UTC 2025
    - 47.8K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/MultipartBody.kt

              this.type = type
            }
    
          /** Add a part to the body. */
          fun addPart(body: RequestBody) =
            apply {
              addPart(Part.create(body))
            }
    
          /** Add a part to the body. */
          fun addPart(
            headers: Headers?,
            body: RequestBody,
          ) = apply {
            addPart(Part.create(headers, body))
          }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/MultipartReaderTest.kt

            boundary = "simple boundary",
            source = Buffer().writeUtf8(multipart),
          )
    
        val part = parts.nextPart()!!
        assertThat(part.body.readUtf8()).isEqualTo("abcd\r\n--simple boundar\r\n\r\nefgh")
    
        assertThat(parts.nextPart()).isNull()
      }
    
      @Test fun `do not need to read entire part`() {
        val multipart =
          """
          |--simple boundary
          |
          |abcd
          |efgh
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 02:11:14 UTC 2025
    - 15.4K bytes
    - Viewed (0)
Back to top