Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 528 for Spread (0.06 sec)

  1. docs/distributed/README.md

    - **Each object is written to a single EC set, and therefore is spread over no more than 16 drives.**
    - **All the nodes running distributed MinIO setup are recommended to be homogeneous, i.e. same operating system, same number of drives and same network interconnects.**
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  2. docs/distributed/DESIGN.md

    - In this algorithm, we also make sure that we spread the drives out evenly. MinIO server expands ellipses passed as arguments. Here is a sample expansion to demonstrate the process.
    
    ```
    minio server http://host{1...2}/export{1...8}
    ```
    
    Expected expansion
    
    ```
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 15 23:04:20 UTC 2023
    - 8K bytes
    - Viewed (0)
  3. android/guava-tests/benchmark/com/google/common/util/concurrent/AbstractFutureFootprintBenchmark.java

      @Footprint(exclude = {Runnable.class, Executor.class, Thread.class, Exception.class})
      public Object measureSize() {
        for (Thread thread : blockedThreads) {
          thread.interrupt();
        }
        blockedThreads.clear();
        final Facade<Object> f = impl.newFacade();
        for (int i = 0; i < numThreads; i++) {
          Thread thread =
              new Thread() {
                @Override
                public void run() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 17:21:56 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  4. docs/contribute/concurrency.md

    So we have a dedicated thread for every socket that just reads frames and dispatches them.
    
    The reader thread must never run application-layer code. Otherwise one slow stream can hold up the entire connection.
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb1/smb1/TestLocking.java

                    t.delay = Long.parseLong(args[ai]);
                } else {
                    t.url = args[ai];
                }
            }
    
            Thread[] threads = new Thread[t.numThreads];
            int ti;
    
            for (ti = 0; ti < t.numThreads; ti++) {
                threads[ti] = new Thread(t);
                System.out.print(threads[ti].getName());
                threads[ti].start();
            }
    
            while (t.numComplete < t.numThreads) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 3.4K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/io/ResourcesTest.java

        ClassLoader oldContextLoader = Thread.currentThread().getContextClassLoader();
        try {
          Thread.currentThread().setContextClassLoader(loader);
          URL url = Resources.getResource(tempFile.getName());
          String text = Resources.toString(url, UTF_8);
          assertEquals("rud a chur ar an méar fhada" + System.lineSeparator(), text);
        } finally {
          Thread.currentThread().setContextClassLoader(oldContextLoader);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/util/transport/Transport.java

                        throw te;
                }
    
                state = 1;
                te = null;
                thread = new Thread( this, name );
                thread.setDaemon( true );
    
                synchronized (thread) {
                    thread.start();
                    thread.wait( timeout );          /* wait for doConnect */
    
                    switch (state) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 9K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java

        @Override
        public boolean offer(E o) {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.offer(o);
        }
    
        @Override
        public @Nullable E poll() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.poll();
        }
    
        @Override
        public E remove() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.remove();
        }
    
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Aug 06 17:23:04 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java

     *   <li>a {@linkplain ThreadFactoryBuilder#setNameFormat naming format}
     *   <li>a {@linkplain Thread#setPriority thread priority}
     *   <li>an {@linkplain Thread#setUncaughtExceptionHandler uncaught exception handler}
     *   <li>a {@linkplain ThreadFactory#newThread backing thread factory}
     * </ul>
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 14 22:50:54 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/collect/SynchronizedTableTest.java

        @Override
        public String toString() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.toString();
        }
    
        @Override
        public boolean equals(@Nullable Object o) {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.equals(o);
        }
    
        @Override
        public int hashCode() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.hashCode();
        }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Aug 06 17:23:04 UTC 2024
    - 4.6K bytes
    - Viewed (0)
Back to top