File tree Expand file tree Collapse file tree 1 file changed +11
-7
lines changed
src/main/java/org/tron/common/overlay/server Expand file tree Collapse file tree 1 file changed +11
-7
lines changed Original file line number Diff line number Diff line change 1717 */
1818package org .tron .common .overlay .server ;
1919
20+ import java .util .ArrayList ;
21+ import java .util .Collections ;
22+ import java .util .Comparator ;
23+ import java .util .HashSet ;
24+ import java .util .List ;
25+ import java .util .Set ;
26+ import java .util .concurrent .Executors ;
27+ import java .util .concurrent .ScheduledExecutorService ;
28+ import java .util .concurrent .TimeUnit ;
29+ import java .util .function .Predicate ;
2030import org .slf4j .Logger ;
2131import org .slf4j .LoggerFactory ;
2232import org .springframework .beans .factory .annotation .Autowired ;
2939import org .tron .core .net .peer .PeerConnection ;
3040import org .tron .core .net .peer .PeerConnectionDelegate ;
3141
32- import java .util .*;
33- import java .util .concurrent .Executors ;
34- import java .util .concurrent .ScheduledExecutorService ;
35- import java .util .concurrent .TimeUnit ;
36- import java .util .function .Predicate ;
37-
3842@ Component
3943public class SyncPool {
4044
@@ -54,7 +58,7 @@ public class SyncPool {
5458
5559 private Args args = Args .getInstance ();
5660
57- private int maxActiveNodes = args .getNodeMaxActiveNodes () > 0 ? args .getNodeMaxActiveNodes () : 3000 ;
61+ private int maxActiveNodes = args .getNodeMaxActiveNodes () > 0 ? args .getNodeMaxActiveNodes () : 30 ;
5862
5963 private ScheduledExecutorService poolLoopExecutor = Executors .newSingleThreadScheduledExecutor ();
6064
You can’t perform that action at this time.
0 commit comments