@@ -48,13 +48,17 @@ public void testScalingThreadPoolConfiguration() throws InterruptedException {
48
48
core = "generic" .equals (threadPoolName ) ? 4 : 1 ; // the defaults
49
49
}
50
50
51
+ final int availableProcessors = Runtime .getRuntime ().availableProcessors ();
51
52
final int maxBasedOnNumberOfProcessors ;
53
+ final int processorsUsed ;
52
54
if (randomBoolean ()) {
53
55
final int processors = randomIntBetween (1 , 64 );
54
56
maxBasedOnNumberOfProcessors = expectedSize (threadPoolName , processors );
55
57
builder .put ("processors" , processors );
58
+ processorsUsed = processors ;
56
59
} else {
57
- maxBasedOnNumberOfProcessors = expectedSize (threadPoolName , Runtime .getRuntime ().availableProcessors ());
60
+ maxBasedOnNumberOfProcessors = expectedSize (threadPoolName , availableProcessors );
61
+ processorsUsed = availableProcessors ;
58
62
}
59
63
60
64
final int expectedMax ;
@@ -93,6 +97,11 @@ public void testScalingThreadPoolConfiguration() throws InterruptedException {
93
97
assertThat (info .getMax (), equalTo (expectedMax ));
94
98
assertThat (esThreadPoolExecutor .getMaximumPoolSize (), equalTo (expectedMax ));
95
99
});
100
+
101
+ if (processorsUsed > availableProcessors ) {
102
+ assertWarnings ("setting processors to value [" + processorsUsed +
103
+ "] which is more than available processors [" + availableProcessors + "] is deprecated" );
104
+ }
96
105
}
97
106
98
107
private int expectedSize (final String threadPoolName , final int numberOfProcessors ) {
0 commit comments