admin/spring-projects-spring-framework
1
0
Fork 0
mirror of https://github.com/spring-projects/spring-framework synced 2026-06-08 17:33:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add concurrency throttle and flexible task callback to SyncTaskExecutor

Browse Source 
Closes gh-35460
This commit is contained in:
Juergen Hoeller
2025-10-11 13:25:30 +02:00
parent 26c57cecd2
commit 8b36736344
5 changed files with 225 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
spring-context/src/test/java/org/springframework/resilience/ConcurrencyLimitTests.java
+7 -3
View File
@@ -59,7 +59,8 @@ class ConcurrencyLimitTests {
futures.add(CompletableFuture.runAsync(proxy::concurrentOperation));
}
CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).join();
assertThat(target.counter).hasValue(0);
assertThat(target.current).hasValue(0);
assertThat(target.counter).hasValue(10);
}
@Test
@@ -166,10 +167,12 @@ class ConcurrencyLimitTests {
static class NonAnnotatedBean {
final AtomicInteger current = new AtomicInteger();
final AtomicInteger counter = new AtomicInteger();
public void concurrentOperation() {
if (counter.incrementAndGet() > 2) {
if (current.incrementAndGet() > 2) {
throw new IllegalStateException();
}
try {
@@ -178,7 +181,8 @@ class ConcurrencyLimitTests {
catch (InterruptedException ex) {
throw new IllegalStateException(ex);
}
counter.decrementAndGet();
current.decrementAndGet();
counter.incrementAndGet();
}
}