- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for backpressure (0.07 sec)
-
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);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 23.2K bytes - Viewed (0) -
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"); } }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 33.4K bytes - Viewed (0) -
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.
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 12.7K bytes - Viewed (0)