Skip to content

Commit 0d30078

Browse files
committed
No use case for a sequential processor yet, add support for delayed tasks.
1 parent 8e60598 commit 0d30078

File tree

1 file changed

+8
-10
lines changed

1 file changed

+8
-10
lines changed

visualvm/core/src/org/graalvm/visualvm/core/VisualVM.java

Lines changed: 8 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -35,30 +35,28 @@ public final class VisualVM {
3535
private static final VisualVM INSTANCE = new VisualVM();
3636

3737

38-
private final int PARALLEL_PROCESSOR_THROUGHPUT_DEFAULT = 10;
39-
private final int PARALLEL_PROCESSOR_THROUGHPUT = Integer.getInteger("org.graalvm.visualvm.core.parallelProcessorThroughput", // NOI18N
40-
PARALLEL_PROCESSOR_THROUGHPUT_DEFAULT);
38+
private final int TASK_PROCESSOR_THROUGHPUT_DEFAULT = 30;
39+
private final int TASK_PROCESSOR_THROUGHPUT = Integer.getInteger("org.graalvm.visualvm.core.taskProcessorThroughput", // NOI18N
40+
TASK_PROCESSOR_THROUGHPUT_DEFAULT);
4141

4242

43-
private final RequestProcessor parallelProcessor;
44-
private final RequestProcessor sequentialProcessor;
43+
private final RequestProcessor taskProcessor;
4544

4645

4746
private VisualVM() {
48-
parallelProcessor = new RequestProcessor("VisualVM Parallel RequestProcessor", PARALLEL_PROCESSOR_THROUGHPUT); // NOI18N
49-
sequentialProcessor = new RequestProcessor("VisualVM Sequential RequestProcessor"); // NOI18N
47+
taskProcessor = new RequestProcessor("VisualVM Shared RequestProcessor", TASK_PROCESSOR_THROUGHPUT); // NOI18N
5048
}
5149

5250

5351
public static VisualVM getInstance() { return INSTANCE; }
5452

5553

5654
public final void runTask(Runnable task) {
57-
parallelProcessor.post(task);
55+
taskProcessor.post(task);
5856
}
5957

60-
public final void runSequentialTask(Runnable task) {
61-
sequentialProcessor.post(task);
58+
public final void runTask(Runnable task, int timeToWait) {
59+
taskProcessor.post(task, timeToWait);
6260
}
6361

6462
}

0 commit comments

Comments
 (0)