Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 41 for Executing (0.07 seconds)

  1. src/test/java/org/codelibs/fess/query/BoostQueryCommandTest.java

            assertEquals("BoostQuery", boostQueryCommand.getQueryClassName());
        }
    
        @Test
        public void test_execute_withTermQuery() {
            // Test executing BoostQuery with a TermQuery inside
            Term term = new Term("field", "value");
            TermQuery termQuery = new TermQuery(term);
            BoostQuery boostQuery = new BoostQuery(termQuery, 2.5f);
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 17K bytes
    - Click Count (0)
  2. internal/stmt_store/stmt_store.go

    	//   connPool: A connection pool that provides database connections.
    	//   locker: A synchronization lock that is unlocked after initialization to avoid deadlocks.
    	// Returns:
    	//   *Stmt: A newly created statement object for executing SQL operations.
    	//   error: An error if the statement preparation fails.
    	New(ctx context.Context, key string, isTransaction bool, connPool ConnPool, locker sync.Locker) (*Stmt, error)
    
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Mar 21 11:35:55 GMT 2026
    - 6.1K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

        // contract to guarantee ordering among runnables we'd have to modify the logic here to allow
        // it.
        executeListener(runnable, executor);
      }
    
      /**
       * Runs this execution list, executing all existing pairs in the order they were added. However,
       * note that listeners added after this point may be executed before those previously added, and
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Feb 10 11:51:21 GMT 2026
    - 6.9K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

        Class<?> ensureLoaded = LockSupport.class;
      }
    
      private static final class DoNothingRunnable implements Runnable {
        @Override
        public void run() {}
      }
    
      // The thread executing the task publishes itself to the superclass' reference and the thread
      // interrupting sets DONE when it has finished interrupting.
      private static final Runnable DONE = new DoNothingRunnable();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 10K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/hash/BloomFilterStrategies.java

          return (data.get((int) (bitIndex >>> LONG_ADDRESSABLE_BITS)) & (1L << bitIndex)) != 0;
        }
    
        /**
         * Careful here: if threads are mutating the atomicLongArray while this method is executing, the
         * final long[] will be a "rolling snapshot" of the state of the bit array. This is usually good
         * enough, but should be kept in mind.
         */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 19 18:53:45 GMT 2026
    - 10.7K bytes
    - Click Count (0)
  6. docs/en/docs/advanced/settings.md

    {* ../../docs_src/settings/app03_an_py310/main.py hl[1,11] *}
    
    Then for any subsequent call of `get_settings()` in the dependencies for the next requests, instead of executing the internal code of `get_settings()` and creating a new `Settings` object, it will return the same object that was returned on the first call, again and again.
    
    #### `lru_cache` Technical Details { #lru-cache-technical-details }
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 10.9K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

          logger.removeHandler(logHandler);
        }
    
        assertEquals(1, logHandler.getStoredLogRecords().size());
        assertThat(logHandler.getStoredLogRecords().get(0).getMessage())
            .isEqualTo("Exception while executing callback: MyListener custom-label");
      }
    
      public void testEnqueueAndDispatch_multithreaded() throws InterruptedException {
        Object listener = new Object();
        ExecutorService service = newFixedThreadPool(4);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 8.4K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

          logger.removeHandler(logHandler);
        }
    
        assertEquals(1, logHandler.getStoredLogRecords().size());
        assertThat(logHandler.getStoredLogRecords().get(0).getMessage())
            .isEqualTo("Exception while executing callback: MyListener custom-label");
      }
    
      public void testEnqueueAndDispatch_multithreaded() throws InterruptedException {
        Object listener = new Object();
        ExecutorService service = newFixedThreadPool(4);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 8.4K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/curl/CurlRequest.java

        protected String compression = null;
    
        /**
         * The SSL socket factory for secure connections.
         */
        protected SSLSocketFactory sslSocketFactory = null;
    
        /**
         * The thread pool for executing the request.
         */
        protected ForkJoinPool threadPool;
    
        /**
         * The connection builder for customizing the connection.
         */
    Created: Thu Apr 02 15:34:12 GMT 2026
    - Last Modified: Sat Mar 21 09:11:12 GMT 2026
    - 19.7K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/ListenableFuture.java

       * <i>happen-before</i></a> its execution begins, perhaps in another thread.
       *
       * <p>Guava implementations of {@code ListenableFuture} promptly release references to listeners
       * after executing them.
       *
       * @param listener the listener to run when the computation is complete
       * @param executor the executor to run the listener in
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 22:14:05 GMT 2026
    - 8K bytes
    - Click Count (0)
Back to Top