Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 251 - 260 of 319 for cluster (0.04 seconds)

  1. android/guava-testlib/src/com/google/common/collect/testing/SpliteratorTester.java

            }
            long size = spliterator.getExactSizeIfKnown();
            long[] counter = {0};
            spliterator.forEachRemaining(
                e -> {
                  consumer.accept(e);
                  counter[0]++;
                });
            if (size >= 0) {
              assertEquals(size, counter[0]);
            }
          }
        },
        ALTERNATE_ADVANCE_AND_SPLIT {
          @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 15:50:50 GMT 2025
    - 12.5K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/base/SuppliersTest.java

        Supplier<Integer> nonThreadSafe =
            new Supplier<Integer>() {
              int counter = 0;
    
              @Override
              public Integer get() {
                int nextValue = counter + 1;
                Thread.yield();
                counter = nextValue;
                return counter;
              }
            };
    
        int numThreads = 10;
        int iterations = 1000;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 16:03:47 GMT 2025
    - 17.9K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/base/SuppliersTest.java

        Supplier<Integer> nonThreadSafe =
            new Supplier<Integer>() {
              int counter = 0;
    
              @Override
              public Integer get() {
                int nextValue = counter + 1;
                Thread.yield();
                counter = nextValue;
                return counter;
              }
            };
    
        int numThreads = 10;
        int iterations = 1000;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 16:03:47 GMT 2025
    - 17.9K bytes
    - Click Count (0)
  4. docs/orchestration/kubernetes/README.md

    ## MinIO Deployment on Kubernetes
    
    There are multiple options to deploy MinIO on Kubernetes:
    
    - MinIO-Operator: Operator offers seamless way to create and update highly available distributed MinIO clusters. Refer [MinIO Operator documentation](https://github.com/minio/minio-operator/blob/master/README.md) for more details.
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 1.6K bytes
    - Click Count (0)
  5. guava/src/com/google/common/io/Files.java

        }
    
        @Override
        public byte[] read() throws IOException {
          Closer closer = Closer.create();
          try {
            FileInputStream in = closer.register(openStream());
            return ByteStreams.toByteArray(in, in.getChannel().size());
          } catch (Throwable e) {
            throw closer.rethrow(e);
          } finally {
            closer.close();
          }
        }
    
        @Override
        public String toString() {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Sep 25 20:24:13 GMT 2025
    - 32.8K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

      private WorkerRunningState workerRunningState = IDLE;
    
      /**
       * This counter prevents an ABA issue where a thread may successfully schedule the worker, the
       * worker runs and exhausts the queue, another thread enqueues a task and fails to schedule the
       * worker, and then the first thread's call to delegate.execute() returns. Without this counter,
       * it would observe the QUEUING state and set it to QUEUED, and the worker would never be
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 10.6K bytes
    - Click Count (0)
  7. guava/src/com/google/common/util/concurrent/SequentialExecutor.java

      private WorkerRunningState workerRunningState = IDLE;
    
      /**
       * This counter prevents an ABA issue where a thread may successfully schedule the worker, the
       * worker runs and exhausts the queue, another thread enqueues a task and fails to schedule the
       * worker, and then the first thread's call to delegate.execute() returns. Without this counter,
       * it would observe the QUEUING state and set it to QUEUED, and the worker would never be
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 10.6K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/reflect/ClassPathTest.java

        manifest.getMainAttributes().put(Attributes.Name.CLASS_PATH, jarFile.getName());
    
        Closer closer = Closer.create();
        try {
          FileOutputStream fileOut = closer.register(new FileOutputStream(jarFile));
          JarOutputStream jarOut = closer.register(new JarOutputStream(fileOut, manifest));
          for (String entry : entries) {
            jarOut.putNextEntry(new ZipEntry(entry));
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 21:00:51 GMT 2025
    - 25.7K bytes
    - Click Count (0)
  9. internal/http/response-recorder.go

    		lrw.headersLogged = true
    		lrw.ResponseWriter.WriteHeader(code)
    	}
    }
    
    // Flush - Calls the underlying Flush.
    func (lrw *ResponseRecorder) Flush() {
    	if flusher, ok := lrw.ResponseWriter.(http.Flusher); ok {
    		flusher.Flush()
    	}
    }
    
    // Size - returns  the number of bytes written
    func (lrw *ResponseRecorder) Size() int {
    	return lrw.bytesWritten
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 5.5K bytes
    - Click Count (0)
  10. internal/http/flush.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package http
    
    import "net/http"
    
    // Flush the ResponseWriter.
    func Flush(w http.ResponseWriter) {
    	if f, ok := w.(http.Flusher); ok {
    		f.Flush()
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 914 bytes
    - Click Count (0)
Back to Top