Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 3 of 3 for backpressure (0.06 seconds)

  1. src/test/java/jcifs/util/SmbCircuitBreakerTest.java

            }
        }
    
        @Test
        public void testBackpressureControl() throws Exception {
            // Create circuit breaker with backpressure enabled
            SmbCircuitBreaker backpressureCircuitBreaker = new SmbCircuitBreaker("backpressure-test", 5, 2, 1000, 3, false, true, 2);
    
            try {
                CountDownLatch startLatch = new CountDownLatch(1);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 23.2K bytes
    - Click Count (0)
  2. src/main/java/jcifs/util/SmbCircuitBreaker.java

            // Backpressure control
            if (backpressureEnabled && requestSemaphore != null) {
                if (!requestSemaphore.tryAcquire()) {
                    totalBackpressureRejections.incrementAndGet();
                    throw new CIFSException("Circuit breaker '" + name + "' rejected request due to backpressure");
                }
            }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 33.4K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/eventbus/EventBus.java

     *       doesn't offer a way to wait for multiple producers to all report that they're "ready," nor
     *       does it offer a way to batch multiple events from a single producer together.
     *   <li>It doesn't support backpressure and other features needed for resilience.
     *   <li>It doesn't provide much control of threading.
     *   <li>It doesn't offer much monitoring.
     *   <li>It doesn't propagate exceptions, so apps don't have a way to react to them.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 12.7K bytes
    - Click Count (0)
Back to Top