File tree Expand file tree Collapse file tree 3 files changed +4
-4
lines changed
main/java/conseq4j/execute
test/java/conseq4j/summon Expand file tree Collapse file tree 3 files changed +4
-4
lines changed Original file line number Diff line number Diff line change 27
27
<modelVersion >4.0.0</modelVersion >
28
28
<groupId >io.github.q3769</groupId >
29
29
<artifactId >conseq4j</artifactId >
30
- <version >20250314.0.0 </version >
30
+ <version >20250314.0.2025 </version >
31
31
<packaging >jar</packaging >
32
32
<name >conseq4j</name >
33
33
<description >A Java concurrent API to sequence related tasks while concurring unrelated ones</description >
Original file line number Diff line number Diff line change @@ -55,8 +55,8 @@ public final class ConseqExecutor implements SequentialExecutor {
55
55
* An ExecutorService used for administrative tasks, such as cleaning up completed tasks from the
56
56
* activeSequentialTasks map.
57
57
*/
58
- private final ExecutorService adminExecutorService = Executors . newThreadPerTaskExecutor (
59
- Thread . ofVirtual (). name ( "conseq-unbounded-admin-vt-" , 1 ). factory () );
58
+ private final ExecutorService adminExecutorService =
59
+ MoreExecutors . newVirtualThreadPerTaskExecutor ( "conseq-unbounded-admin-vt-" );
60
60
61
61
/**
62
62
* The worker thread pool facilitates the overall async execution, independent of the submitted
Original file line number Diff line number Diff line change @@ -72,7 +72,7 @@ void concurrencyBoundedByTotalTaskCount() {
72
72
void higherConcurrencyRendersBetterThroughput () {
73
73
List <SpyingTask > sameTasks = createSpyingTasks (TASK_COUNT );
74
74
int lowConcurrency = 2 ;
75
- int highConcurrency = lowConcurrency * 10 ;
75
+ int highConcurrency = lowConcurrency * 20 ;
76
76
77
77
long lowConcurrencyStart ;
78
78
List <Future <SpyingTask >> lowConcurrencyFutures ;
You can’t perform that action at this time.
0 commit comments