From 7d6808cbcfbb0f61f93e536d36968eeda5bd302c Mon Sep 17 00:00:00 2001
From: Luck <git@lucko.me>
Date: Wed, 6 Jun 2018 15:39:16 +0100
Subject: Convert to Gradle

---
 .../me/lucko/spark/profiler/SamplerBuilder.java    | 63 ++++++++++++++++++++++
 1 file changed, 63 insertions(+)
 create mode 100644 spark-common/src/main/java/me/lucko/spark/profiler/SamplerBuilder.java

(limited to 'spark-common/src/main/java/me/lucko/spark/profiler/SamplerBuilder.java')

diff --git a/spark-common/src/main/java/me/lucko/spark/profiler/SamplerBuilder.java b/spark-common/src/main/java/me/lucko/spark/profiler/SamplerBuilder.java
new file mode 100644
index 0000000..7db0515
--- /dev/null
+++ b/spark-common/src/main/java/me/lucko/spark/profiler/SamplerBuilder.java
@@ -0,0 +1,63 @@
+package me.lucko.spark.profiler;
+
+import java.util.Timer;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * Builds {@link Sampler} instances.
+ */
+public class SamplerBuilder {
+
+    private int samplingInterval = 4;
+    private long timeout = -1;
+    private ThreadDumper threadDumper = ThreadDumper.ALL;
+    private ThreadGrouper threadGrouper = ThreadGrouper.BY_NAME;
+
+    private int ticksOver = -1;
+    private TickCounter tickCounter = null;
+
+    public SamplerBuilder() {
+    }
+
+    public SamplerBuilder samplingInterval(int samplingInterval) {
+        this.samplingInterval = samplingInterval;
+        return this;
+    }
+
+    public SamplerBuilder completeAfter(long timeout, TimeUnit unit) {
+        if (timeout <= 0) {
+            throw new IllegalArgumentException("timeout > 0");
+        }
+        this.timeout = System.currentTimeMillis() + unit.toMillis(timeout);
+        return this;
+    }
+
+    public SamplerBuilder threadDumper(ThreadDumper threadDumper) {
+        this.threadDumper = threadDumper;
+        return this;
+    }
+
+    public SamplerBuilder threadGrouper(ThreadGrouper threadGrouper) {
+        this.threadGrouper = threadGrouper;
+        return this;
+    }
+
+    public SamplerBuilder ticksOver(int ticksOver, TickCounter tickCounter) {
+        this.ticksOver = ticksOver;
+        this.tickCounter = tickCounter;
+        return this;
+    }
+
+    public Sampler start(Timer samplingThread) {
+        Sampler sampler;
+        if (this.ticksOver != -1 && this.tickCounter != null) {
+            sampler = new Sampler(this.samplingInterval, this.threadDumper, this.threadGrouper, this.timeout, this.tickCounter, this.ticksOver);
+        } else {
+            sampler = new Sampler(this.samplingInterval, this.threadDumper, this.threadGrouper, this.timeout);
+        }
+
+        sampler.start(samplingThread);
+        return sampler;
+    }
+
+}
-- 
cgit