- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for backpressureEnabled (0.07 sec)
-
src/main/java/jcifs/util/SmbCircuitBreaker.java
this.dynamicThresholdEnabled = dynamicThresholdEnabled; this.backpressureEnabled = backpressureEnabled; this.maxConcurrentRequests = maxConcurrentRequests; this.requestSemaphore = backpressureEnabled ? new Semaphore(maxConcurrentRequests, true) : null; // Initialize scheduler for dynamic threshold adjustment this.scheduler =
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 33.4K bytes - Viewed (0) -
src/test/java/jcifs/util/SmbCircuitBreakerTest.java
3, // successThreshold 2000, // resetTimeoutMillis 5, // halfOpenMaxAttempts true, // dynamicThresholdEnabled true, // backpressureEnabled 50 // maxConcurrentRequests ); try { assertEquals("full-test", fullCb.getName()); assertEquals(7, fullCb.getCurrentFailureThreshold());
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 23.2K bytes - Viewed (0)