diff options
author | lucko <git@lucko.me> | 2022-06-09 22:13:58 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-06-09 22:13:58 +0100 |
commit | 4a16a1a2f4eb09f706b4a541e3d31618de29420b (patch) | |
tree | cc320ee2e6551f2157a2d54968f8ba14f6713d08 /spark-common/src/main/java/me/lucko/spark/common/tick | |
parent | 32ab78c71c5be97da7329a4f7c4035289a3490b1 (diff) | |
parent | ecc3714e6441ace0eb78156b2b4475ca050280db (diff) | |
download | spark-4a16a1a2f4eb09f706b4a541e3d31618de29420b.tar.gz spark-4a16a1a2f4eb09f706b4a541e3d31618de29420b.tar.bz2 spark-4a16a1a2f4eb09f706b4a541e3d31618de29420b.zip |
Merge pull request #213 from embeddedt/forge-1.7.10
Align 1.7.10 with Spark 1.9
Diffstat (limited to 'spark-common/src/main/java/me/lucko/spark/common/tick')
-rw-r--r-- | spark-common/src/main/java/me/lucko/spark/common/tick/AbstractTickHook.java | 4 | ||||
-rw-r--r-- | spark-common/src/main/java/me/lucko/spark/common/tick/AbstractTickReporter.java | 4 |
2 files changed, 4 insertions, 4 deletions
diff --git a/spark-common/src/main/java/me/lucko/spark/common/tick/AbstractTickHook.java b/spark-common/src/main/java/me/lucko/spark/common/tick/AbstractTickHook.java index a6e8745..2a31e0d 100644 --- a/spark-common/src/main/java/me/lucko/spark/common/tick/AbstractTickHook.java +++ b/spark-common/src/main/java/me/lucko/spark/common/tick/AbstractTickHook.java @@ -20,12 +20,12 @@ package me.lucko.spark.common.tick; -import java.util.HashSet; import java.util.Set; +import java.util.concurrent.CopyOnWriteArraySet; public abstract class AbstractTickHook implements TickHook { - private final Set<Callback> tasks = new HashSet<>(); + private final Set<Callback> tasks = new CopyOnWriteArraySet<>(); private int tick = 0; protected void onTick() { diff --git a/spark-common/src/main/java/me/lucko/spark/common/tick/AbstractTickReporter.java b/spark-common/src/main/java/me/lucko/spark/common/tick/AbstractTickReporter.java index 74a814d..431a641 100644 --- a/spark-common/src/main/java/me/lucko/spark/common/tick/AbstractTickReporter.java +++ b/spark-common/src/main/java/me/lucko/spark/common/tick/AbstractTickReporter.java @@ -20,11 +20,11 @@ package me.lucko.spark.common.tick; -import java.util.HashSet; import java.util.Set; +import java.util.concurrent.CopyOnWriteArraySet; public abstract class AbstractTickReporter implements TickReporter { - private final Set<Callback> tasks = new HashSet<>(); + private final Set<Callback> tasks = new CopyOnWriteArraySet<>(); protected void onTick(double duration) { for (Callback r : this.tasks) { |