File tree Expand file tree Collapse file tree
hugegraph-server/hugegraph-core/src/main/java/org/apache/hugegraph/task Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1717
1818package org .apache .hugegraph .task ;
1919
20+ import java .util .ArrayList ;
21+ import java .util .Date ;
22+ import java .util .HashMap ;
23+ import java .util .List ;
24+ import java .util .Map ;
25+
2026import org .apache .hugegraph .HugeGraph ;
2127import org .apache .hugegraph .HugeGraphParams ;
2228import org .apache .hugegraph .backend .id .Id ;
3743import org .apache .tinkerpop .gremlin .structure .Vertex ;
3844import org .apache .tinkerpop .gremlin .structure .VertexProperty ;
3945
40- import java .util .*;
41-
4246public class HugeServerInfo {
4347
4448 // Unit millisecond
Original file line number Diff line number Diff line change 1717
1818package org .apache .hugegraph .task ;
1919
20+ import java .util .ArrayList ;
21+ import java .util .Iterator ;
22+ import java .util .List ;
23+ import java .util .Map ;
24+ import java .util .concurrent .Callable ;
25+ import java .util .concurrent .ConcurrentHashMap ;
26+ import java .util .concurrent .ExecutorService ;
27+ import java .util .concurrent .Executors ;
28+ import java .util .concurrent .Future ;
29+ import java .util .concurrent .TimeoutException ;
30+
2031import com .google .common .collect .ImmutableMap ;
2132import org .apache .hugegraph .HugeException ;
2233import org .apache .hugegraph .HugeGraph ;
4657import org .apache .tinkerpop .gremlin .structure .Vertex ;
4758import org .slf4j .Logger ;
4859
49- import java .util .ArrayList ;
50- import java .util .Iterator ;
51- import java .util .List ;
52- import java .util .Map ;
53- import java .util .concurrent .*;
54-
5560public class StandardTaskScheduler implements TaskScheduler {
5661
5762 private static final Logger LOG = Log .logger (StandardTaskScheduler .class );
Original file line number Diff line number Diff line change 1717
1818package org .apache .hugegraph .task ;
1919
20+ import java .util .Map ;
21+ import java .util .concurrent .Callable ;
22+ import java .util .concurrent .ConcurrentHashMap ;
23+ import java .util .concurrent .ExecutorService ;
24+ import java .util .concurrent .ThreadPoolExecutor ;
25+ import java .util .concurrent .TimeUnit ;
26+ import java .util .concurrent .TimeoutException ;
27+
2028import org .apache .hugegraph .HugeException ;
2129import org .apache .hugegraph .HugeGraphParams ;
2230import org .apache .hugegraph .concurrent .PausableScheduledThreadPool ;
2735import org .apache .hugegraph .util .Log ;
2836import org .slf4j .Logger ;
2937
30- import java .util .Map ;
31- import java .util .concurrent .*;
32-
3338/**
3439 * Central task management system that coordinates task scheduling and execution.
3540 * Manages task schedulers for different graphs and handles role-based execution.
You can’t perform that action at this time.
0 commit comments