diff options
| author | Hannes Greule <SirYwell@users.noreply.github.com> | 2024-07-29 19:50:54 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-07-29 18:50:54 +0100 |
| commit | 7076811d48357cfe22792e4042ce03183b0a791d (patch) | |
| tree | 5de9465cb900f547e930b88c089eea1ad0254708 | |
| parent | 92621758b9e5a2173d871ed4556d30070b094e0f (diff) | |
| download | spark-7076811d48357cfe22792e4042ce03183b0a791d.tar.gz spark-7076811d48357cfe22792e4042ce03183b0a791d.tar.bz2 spark-7076811d48357cfe22792e4042ce03183b0a791d.zip | |
Check for async command completion before sleeping (#431)
| -rw-r--r-- | spark-common/src/main/java/me/lucko/spark/common/SparkPlatform.java | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/spark-common/src/main/java/me/lucko/spark/common/SparkPlatform.java b/spark-common/src/main/java/me/lucko/spark/common/SparkPlatform.java index 5e25d91..f5886b5 100644 --- a/spark-common/src/main/java/me/lucko/spark/common/SparkPlatform.java +++ b/spark-common/src/main/java/me/lucko/spark/common/SparkPlatform.java @@ -372,6 +372,10 @@ public class SparkPlatform { int warningIntervalSeconds = 5; try { + if (completed.get()) { + return; + } + for (int i = 1; i <= 3; i++) { try { Thread.sleep(warningIntervalSeconds * 1000); |