Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for sequential (0.17 sec)

  1. 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);
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Fri Oct 02 16:24:50 GMT 2020
    - 5.9K bytes
    - Viewed (0)
  2. android/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);
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Fri Oct 02 16:24:50 GMT 2020
    - 5.9K bytes
    - Viewed (0)
  3. android/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
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Sun Jun 20 10:45:35 GMT 2021
    - 4.2K bytes
    - Viewed (0)
  4. okhttp/src/main/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,
    ) {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 2.4K bytes
    - Viewed (0)
  5. docs/throttle/README.md

    If you have traditional spinning (hdd) drives, some applications with high concurrency might require MinIO cluster to be tuned such that to avoid random I/O on the drives. The way to convert high concurrent I/O into a sequential I/O is by reducing the number of concurrent operations allowed per cluster. This allows MinIO cluster to be operationally resilient to such workloads, while also making sure the drives are at optimal efficiency and responsive.
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Feb 12 00:51:25 GMT 2022
    - 2.4K bytes
    - Viewed (0)
  6. docs/distributed/CONFIG.md

    server.
    
    Historically everything to MinIO was provided via command arguments for the hostnames and the drives via an ellipses syntax such as `minio server http://host{1...4}/disk{1...4}` this requirement added an additional burden to have sequential hostnames for us to make sure that we can provide horizontal distribution, however we have come across situations where sometimes this is not feasible and there are no easier alternatives without modifying /etc/hosts on the host system as root user....
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  7. maven-core/src/main/java/org/apache/maven/lifecycle/internal/builder/multithreaded/MultiThreadedBuilder.java

     * set with <code>-T</code> on the command-line) and the number of projects to build. As such, building a single project
     * will always result in a sequential build, regardless of the thread count.
     * </p>
     * <strong>NOTE:</strong> This class is not part of any public api and can be changed or deleted without prior notice.
     *
     * @since 3.0
    Java
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Fri Sep 22 09:07:17 GMT 2023
    - 9.4K bytes
    - Viewed (0)
  8. 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) {
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 6.5K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

    import java.util.concurrent.locks.ReentrantLock
    import kotlin.concurrent.withLock
    import okhttp3.internal.assertNotHeld
    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.
     */
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb1/smb1/SmbComNTCreateAndX.java

         */
    
        static final int FILE_OVERWRITE_IF = 0x5;
    
    
        // create options
        static final int FILE_WRITE_THROUGH           = 0x00000002;
        static final int FILE_SEQUENTIAL_ONLY         = 0x00000004;
        static final int FILE_SYNCHRONOUS_IO_ALERT    = 0x00000010;
        static final int FILE_SYNCHRONOUS_IO_NONALERT = 0x00000020;
    
        // security flags
    Java
    - Registered: Sun May 05 00:10:10 GMT 2024
    - Last Modified: Fri Mar 22 21:10:40 GMT 2019
    - 6.6K bytes
    - Viewed (0)
Back to top