Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 65 for sequential (0.06 sec)

  1. src/main/java/org/codelibs/fess/crawler/service/FessUrlQueueService.java

     * This service provides customized URL fetching strategies including sequential and random ordering
     * based on crawling configuration parameters.
     */
    public class FessUrlQueueService extends OpenSearchUrlQueueService {
    
        private static final Logger logger = LogManager.getLogger(FessUrlQueueService.class);
    
        /** Configuration value for sequential URL processing order */
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 4K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/hash/FunnelsTest.java

        @SuppressWarnings({"unchecked", "DoNotMock"})
        Funnel<Object> elementFunnel = mock(Funnel.class);
        PrimitiveSink primitiveSink = mock(PrimitiveSink.class);
        Funnel<Iterable<?>> sequential = Funnels.sequentialFunnel(elementFunnel);
        sequential.funnel(Arrays.asList("foo", "bar", "baz", "quux"), primitiveSink);
        InOrder inOrder = inOrder(elementFunnel);
        inOrder.verify(elementFunnel).funnel("foo", primitiveSink);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/ListeningExecutorService.java

       *   {@code List<ListenableFuture<T>> futures = (List) executor.invokeAll(tasks);}
       * </pre>
       *
       * @return A list of {@code ListenableFuture} instances representing the tasks, in the same
       *     sequential order as produced by the iterator for the given task list, each of which has
       *     completed.
       * @throws RejectedExecutionException {@inheritDoc}
       * @throws NullPointerException if any task is null
       */
      @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/Task.kt

     * decide not to by returning -1L.
     *
     * Task Queues
     * -----------
     *
     * Tasks are bound to the [TaskQueue] they are scheduled in. Each queue is sequential and the tasks
     * within it never execute concurrently. It is an error to use a task in multiple queues.
     */
    abstract class Task(
      val name: String,
      val cancelable: Boolean = true,
    ) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  5. src/test/java/jcifs/FileNotifyInformationTest.java

            void testFileActionRemovedByDelete() {
                assertEquals(0x00000009, FileNotifyInformation.FILE_ACTION_REMOVED_BY_DELETE);
            }
    
            @Test
            @DisplayName("Verify action constants are sequential and unique")
            void testActionConstantsAreUnique() {
                int[] actions = { FileNotifyInformation.FILE_ACTION_ADDED, FileNotifyInformation.FILE_ACTION_REMOVED,
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 18.1K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/fess/dict/DictionaryItemTest.java

            assertEquals(999L, item.getId());
    
            // Verify direct field access
            assertEquals(999L, item.id);
        }
    
        public void test_sequentialIdAssignment() {
            // Test sequential ID assignment pattern
            TestDictionaryItem[] items = new TestDictionaryItem[5];
    
            for (int i = 0; i < items.length; i++) {
                items[i] = new TestDictionaryItem();
                items[i].id = i + 1;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 4.1K bytes
    - Viewed (0)
  7. guava-testlib/src/com/google/common/testing/CollectorTester.java

       * Different orderings for combining the elements of an input array, which must all produce the
       * same result.
       */
      enum CollectStrategy {
        /** Get one accumulator and accumulate the elements into it sequentially. */
        SEQUENTIAL {
          @Override
          final <T extends @Nullable Object, A extends @Nullable Object, R extends @Nullable Object>
              A result(Collector<T, A, R> collector, Iterable<T> inputs) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu May 15 21:47:56 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/script/ScriptEngineFactoryTest.java

            assertNotNull(retrieved);
            assertEquals(engine, retrieved);
        }
    
        // Test concurrent-like scenario (sequential but simulating concurrent behavior)
        public void test_add_multipleSameNameSequential() {
            TestScriptEngine engine1 = new TestScriptEngine("v1");
            TestScriptEngine engine2 = new TestScriptEngine("v2");
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 12.1K bytes
    - Viewed (0)
  9. okhttp-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/MappingTables.kt

      val mappingsBuffer = StringBuilder()
      val sectionIndexBuffer = Buffer()
    
      var previousMappedRanges: List<MappedRange>? = null
    
      for ((section, sectionMappedRanges) in sections) {
        // Skip sequential ranges when they are equal.
        if (sectionMappedRanges == previousMappedRanges) continue
        previousMappedRanges = sectionMappedRanges
    
        val sectionOffset = rangesBuffer.size.toInt() / 4
    
        // Section prefix.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 8.3K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

    package okhttp3.internal.concurrent
    
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.RejectedExecutionException
    import okhttp3.internal.okHttpName
    
    /**
     * A set of tasks that are executed in sequential order.
     *
     * Work within queues is not concurrent. This is equivalent to each queue having a dedicated thread
     * for its work; in practice a set of queues may share a set of threads to save resources.
     */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 7.3K bytes
    - Viewed (0)
Back to top