eaglercraft/eagler-teavm-fork
1
0
Fork 0
mirror of https://github.com/Eaglercraft-TeaVM-Fork/eagler-teavm.git synced 2024-12-22 16:14:10 -08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Implement some of the missing Timer methods

Browse Source
This commit is contained in:
Alexey Andreev 2020-04-14 16:10:17 +03:00
parent ddf64870da
commit 1681aa5834
1 changed files with 49 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

60
classlib/src/main/java/org/teavm/classlib/java/util/TTimer.java
View File

@ -15,20 +15,35 @@
*/ */
package org.teavm.classlib.java.util; package org.teavm.classlib.java.util;
import java.util.Date;
import java.util.Objects;
import org.teavm.classlib.java.lang.TIllegalStateException; import org.teavm.classlib.java.lang.TIllegalStateException;
import org.teavm.classlib.java.lang.TObject; import org.teavm.classlib.java.lang.TObject;
import org.teavm.classlib.java.lang.TString;
import org.teavm.jso.browser.TimerHandler; import org.teavm.jso.browser.TimerHandler;
import org.teavm.jso.browser.Window; import org.teavm.jso.browser.Window;
public class TTimer extends TObject { public class TTimer extends TObject {
TSet<TTimerTask> tasks = new THashSet<>(); TSet<TTimerTask> tasks = new THashSet<>();
private volatile boolean cancelled; private volatile boolean cancelled;
private String threadName;
private boolean daemon;
public TTimer() { public TTimer() {
} }
public TTimer(@SuppressWarnings("unused") TString name) { public TTimer(String name) {
Objects.requireNonNull(name);
threadName = name;
}
public TTimer(boolean daemon) {
this.daemon = daemon;
}
public TTimer(String name, boolean daemon) {
Objects.requireNonNull(name);
threadName = name;
this.daemon = daemon;
} }
public void cancel() { public void cancel() {
@ -41,29 +56,39 @@ public class TTimer extends TObject {
} }
} }
public void schedule(final TTimerTask task, long delay) { public void schedule(TTimerTask task, Date time) {
long delay = Math.max(0, time.getTime() - System.currentTimeMillis());
schedule(task, delay);
}
public void schedule(TTimerTask task, long delay) {
if (cancelled || task.timer != null || task.nativeTimerId >= 0) { if (cancelled || task.timer != null || task.nativeTimerId >= 0) {
throw new TIllegalStateException(); throw new TIllegalStateException();
} }
task.timer = this; task.timer = this;
task.nativeTimerId = Window.setTimeout(() -> { task.nativeTimerId = Window.setTimeout(() -> {
new Thread(() -> { runThread(new Thread(() -> {
if (cancelled || task.timer == null) { if (cancelled || task.timer == null) {
return; return;
} }
TTimerTask.performOnce(task); TTimerTask.performOnce(task);
}).start(); }));
}, (int) delay); }, (int) delay);
} }
public void schedule(final TTimerTask task, long delay, final long period) { public void schedule(TTimerTask task, Date time, long period) {
long delay = Math.max(0, time.getTime() - System.currentTimeMillis());
schedule(task, delay, period);
}
public void schedule(TTimerTask task, long delay, long period) {
if (cancelled || task.timer != null || task.nativeTimerId >= 0) { if (cancelled || task.timer != null || task.nativeTimerId >= 0) {
throw new TIllegalStateException(); throw new TIllegalStateException();
} }
task.timer = this; task.timer = this;
TimerHandler handler = new TimerHandler() { TimerHandler handler = new TimerHandler() {
@Override public void onTimer() { @Override public void onTimer() {
new Thread(() -> { runThread(new Thread(() -> {
if (cancelled || task.timer == null) { if (cancelled || task.timer == null) {
return; return;
} }
@ -72,13 +97,18 @@ public class TTimer extends TObject {
if (!cancelled) { if (!cancelled) {
task.timer = TTimer.this; task.timer = TTimer.this;
} }
}).start(); }));
} }
}; };
task.nativeTimerId = Window.setTimeout(handler, (int) delay); task.nativeTimerId = Window.setTimeout(handler, (int) delay);
} }
public void scheduleAtFixedRate(final TTimerTask task, long delay, long period) { public void scheduleAtFixedRate(TTimerTask task, Date time, long period) {
long delay = Math.max(0, time.getTime() - System.currentTimeMillis());
scheduleAtFixedRate(task, delay, period);
}
public void scheduleAtFixedRate(TTimerTask task, long delay, long period) {
if (cancelled || task.timer != null || task.nativeTimerId >= 0) { if (cancelled || task.timer != null || task.nativeTimerId >= 0) {
throw new TIllegalStateException(); throw new TIllegalStateException();
} }
@ -86,7 +116,7 @@ public class TTimer extends TObject {
task.timer = this; task.timer = this;
TimerHandler handler = new TimerHandler() { TimerHandler handler = new TimerHandler() {
@Override public void onTimer() { @Override public void onTimer() {
new Thread(() -> { runThread(new Thread(() -> {
if (cancelled || task.timer == null) { if (cancelled || task.timer == null) {
return; return;
} }
@ -100,10 +130,18 @@ public class TTimer extends TObject {
if (!cancelled) { if (!cancelled) {
task.timer = TTimer.this; task.timer = TTimer.this;
} }
}).start(); }));
} }
}; };
task.nativeTimerId = Window.setTimeout(handler, (int) delay); task.nativeTimerId = Window.setTimeout(handler, (int) delay);
nextStartTime[0] += period; nextStartTime[0] += period;
} }
private void runThread(Thread thread) {
if (threadName != null) {
thread.setName(threadName);
thread.setDaemon(daemon);
}
thread.start();
}
} }