Search Options

Results per page
Sort
Preferred Languages
Advance

Results 461 - 470 of 981 for executed (0.05 sec)

  1. integration-tests/gradle/gradlew.bat

    if exist "%JAVA_EXE%" goto execute
    
    echo.
    echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME%
    echo.
    echo Please set the JAVA_HOME variable in your environment to match the
    echo location of your Java installation.
    
    goto fail
    
    :execute
    @rem Setup the command line
    
    set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
    
    
    @rem Execute Gradle
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jun 28 18:15:57 UTC 2023
    - 2.7K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

       */
      public static <V extends @Nullable Object> ListenableFuture<V> listenInPoolThread(
          Future<V> future, Executor executor) {
        checkNotNull(executor);
        if (future instanceof ListenableFuture) {
          return (ListenableFuture<V>) future;
        }
        return new ListenableFutureAdapter<>(future, executor);
      }
    
      /**
       * An adapter to turn a {@link Future} into a {@link ListenableFuture}. This will wait on the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        assertFalse(task.isCancelled());
    
        // Start the task to put it in the RUNNING state.  Have to use a separate
        // thread because the task will block on the task latch after unblocking
        // the run latch.
        exec.execute(task);
        runLatch.await();
        assertEquals(1, listenerLatch.getCount());
        assertFalse(task.isDone());
        assertFalse(task.isCancelled());
    
        // Finish the task by unblocking the task latch.  Then wait for the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        ExecutorService executor = newDirectExecutorService();
        assertEquals(ImmutableList.of(), executor.shutdownNow());
        assertTrue(executor.isShutdown());
      }
    
      public void testExecuteAfterShutdown() {
        ExecutorService executor = newDirectExecutorService();
        executor.shutdown();
        assertThrows(RejectedExecutionException.class, () -> executor.execute(EMPTY_RUNNABLE));
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/tls/ClientAuthTest.kt

        server.useHttps(socketFactory)
        server.requireClientAuth()
        val call = client.newCall(Request.Builder().url(server.url("/")).build())
        assertFailsWith<IOException> {
          call.execute()
        }.also { expected ->
          when (expected) {
            is SSLHandshakeException -> {
              // JDK 11+
            }
            is SSLException -> {
              // javax.net.ssl.SSLException: readRecord
            }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/app/web/go/GoAction.java

        // ===================================================================================
        //                                                                      Search Execute
        //                                                                      ==============
        @Execute
        public ActionResponse index(final GoForm form) throws IOException {
            validate(form, messages -> {}, () -> asHtml(virtualHost(path_Error_ErrorJsp)));
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  7. docs/de/docs/advanced/settings.md

            code ->> function: say_hi(name="Rick")
            function ->> execute: führe Code der Funktion aus
            execute ->> code: gib das Resultat zurück
        end
    
        rect rgba(0, 255, 0, .1)
            code ->> function: say_hi(name="Rick", salutation="Mr.")
            function ->> execute: führe Code der Funktion aus
            execute ->> code: gib das Resultat zurück
        end
    
        rect rgba(0, 255, 255, .1)
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 17.7K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java

            SearchResponse response = client.prepareSearch(index).setSize(500).setScroll(settings.getScrollTimeout())
                    .setQuery(QueryBuilders.rangeQuery(FieldNames.DOC_FREQ).gte(1)).execute().actionGet(settings.getSearchTimeout());
            String scrollId = response.getScrollId();
            try {
                while (scrollId != null) {
                    final SearchHit[] hits = response.getHits().getHits();
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/es/user/allcommon/EsAbstractBehavior.java

                    final BulkResponse bulkResponse = bulkRequest.execute().actionGet(bulkTimeout);
                    if (bulkResponse.hasFailures()) {
                        throw new IllegalBehaviorStateException(bulkResponse.buildFailureMessage());
                    }
    
                    response = client.prepareSearchScroll(scrollId).setScroll(scrollForDelete).execute().actionGet(scrollSearchTimeout);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  10. native-image-tests/src/main/kotlin/okhttp3/SampleTest.kt

        val client = clientRule.newClient()
    
        client.newCall(Request(url = server.url("/"))).execute().use {
          assertThat(it.body.string()).isEqualTo("abc")
        }
      }
    
      @Test
      fun testExternalSite() {
        val client = clientRule.newClient()
    
        client.newCall(Request(url = "https://google.com/robots.txt".toHttpUrl())).execute().use {
          assertThat(it.code).isEqualTo(200)
        }
      }
    
      @ParameterizedTest
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.8K bytes
    - Viewed (0)
Back to top