Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 201 - 210 of 702 for executor (0.06 seconds)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt

     *     .build();
     * Response response = eagerClient.newCall(request).execute();
     * ```
     *
     * ## Shutdown Isn't Necessary
     *
     * The threads and connections that are held will be released automatically if they remain idle. But
     * if you are writing a application that needs to aggressively release unused resources you may do
     * so.
     *
     * Shutdown the dispatcher's executor service with [shutdown()][ExecutorService.shutdown]. This will
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 51.5K bytes
    - Click Count (0)
  2. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt

            .connectionPool(
              buildConnectionPool(
                connectionListener = connectionListener,
                taskRunner = taskRunner,
              ),
            ).dispatcher(Dispatcher(backend.executor))
            .taskRunnerInternal(taskRunner)
        } else {
          OkHttpClient
            .Builder()
            .connectionPool(ConnectionPool(connectionListener = connectionListener))
        }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  3. android/guava-testlib/test/com/google/common/testing/ArbitraryInstancesTest.java

        assertTrue(ArbitraryInstances.get(ConcurrentMap.class).isEmpty());
        assertTrue(ArbitraryInstances.get(ConcurrentNavigableMap.class).isEmpty());
        ArbitraryInstances.get(Executor.class).execute(ArbitraryInstances.get(Runnable.class));
        assertThat(ArbitraryInstances.get(ThreadFactory.class)).isNotNull();
        assertFreshInstanceReturned(
            BlockingQueue.class,
            BlockingDeque.class,
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 22.4K bytes
    - Click Count (0)
  4. impl/maven-core/pom.xml

                  <revisionOnScmFailure>NON_CANONICAL</revisionOnScmFailure>
                </configuration>
              </execution>
            </executions>
          </plugin>
          <plugin>
            <groupId>org.apache.maven.plugins</groupId>
            <artifactId>maven-failsafe-plugin</artifactId>
            <executions>
              <execution>
                <!--  <phase></phase> -->
                <goals>
                  <goal>integration-test</goal>
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Nov 26 10:37:56 GMT 2025
    - 16.9K bytes
    - Click Count (0)
  5. src/main/resources/fess_config.properties

    # Template for data crawler job title.
    job.template.title.data=Data Crawler - {0}
    # Script template for job execution.
    job.template.script=return container.getComponent("crawlJob").logLevel("info").webConfigIds([{0}] as String[]).fileConfigIds([{1}] as String[]).dataConfigIds([{2}] as String[]).jobExecutor(executor).execute();
    # Maximum number of crawler processes.
    job.max.crawler.processes=0
    # Default script language for jobs.
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 59.3K bytes
    - Click Count (0)
  6. docs/changelogs/changelog_3x.md

        implementation("org.bouncycastle:bcprov-jdk15on:1.60")
        implementation("org.conscrypt:conscrypt-openjdk-uber:1.4.0")
        implementation("com.squareup.okio:okio:1.15.0")
        ```
    
     *  Fix: Handle dispatcher executor shutdowns gracefully. When there aren't any threads to carry a
        call its callback now gets a `RejectedExecutionException`.
     *  Fix: Don't permanently cache responses with `Cache-Control: immutable`. We misunderstood the
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 06 14:55:54 GMT 2022
    - 50.8K bytes
    - Click Count (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

            .body("def")
            .throttleBody(1, 750, TimeUnit.MILLISECONDS)
            .build(),
        )
        val call = client.newCall(Request(server.url("/a")))
        val executor = Executors.newSingleThreadExecutor()
        val result = executor.submit<Response?> { call.execute() }
        Thread.sleep(100) // wait for it to go in flight.
        call.cancel()
        assertFailsWith<IOException> {
          result.get()!!.body.bytes()
        }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:02:18 GMT 2026
    - 146.5K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/mylasta/direction/FessConfig.java

         * The value is, e.g. return container.getComponent("crawlJob").logLevel("info").webConfigIds([{0}] as String[]).fileConfigIds([{1}] as String[]).dataConfigIds([{2}] as String[]).jobExecutor(executor).execute(); <br>
         * comment: Script template for job execution.
         * @return The value of found property. (NotNull: if not found, exception but basically no way)
         */
        String getJobTemplateScript();
    
        /**
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 576.9K bytes
    - Click Count (2)
  9. android/guava/src/com/google/common/cache/CacheBuilder.java

     * href="https://www.javadoc.io/doc/com.github.ben-manes.caffeine/caffeine/latest/com.github.benmanes.caffeine/com/github/benmanes/caffeine/cache/AsyncCacheLoader.html#asyncLoad(K,java.util.concurrent.Executor)">{@code
     * AsyncCacheLoader.asyncLoad}</a> must return a {@code CompletableFuture}. Users of Guava's {@link
     * com.google.common.util.concurrent.ListenableFuture} can adapt between the two {@code Future}
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 13:13:59 GMT 2026
    - 52K bytes
    - Click Count (0)
  10. CHANGELOG/CHANGELOG-1.26.md

        - `apiserver_flowcontrol_nominal_limit_seats`: Nominal number of execution seats configured for each priority level
        - `apiserver_flowcontrol_lower_limit_seats`: Configured lower bound on number of execution seats available to each priority level
        - `apiserver_flowcontrol_upper_limit_seats`: Configured upper bound on number of execution seats available to each priority level
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Tue Sep 02 13:51:56 GMT 2025
    - 425.7K bytes
    - Click Count (0)
Back to Top