35 lines
1.2 KiB
TypeScript
35 lines
1.2 KiB
TypeScript
import { task, plugin } from '@ccms/api'
|
|
import { inject, provideSingleton } from '@ccms/container';
|
|
|
|
const NukkitRunnable = Java.type('cn.nukkit.scheduler.NukkitRunnable');
|
|
|
|
@provideSingleton(task.TaskManager)
|
|
export class NukkitTaskManager implements task.TaskManager {
|
|
@inject(plugin.PluginInstance)
|
|
private pluginInstance: any;
|
|
|
|
create(func: Function): task.Task {
|
|
if (Object.prototype.toString.call(func) !== "[object Function]") { throw TypeError('第一个参数 Task 必须为 function !'); };
|
|
return new NukkitTask(this.pluginInstance, func);
|
|
}
|
|
callSyncMethod(func: Function): any {
|
|
return func()
|
|
}
|
|
disable() {
|
|
base.getInstance().getServer().getScheduler().cancelTask(this.pluginInstance)
|
|
}
|
|
}
|
|
|
|
export class NukkitTask extends task.Task {
|
|
submit(...args: any[]): task.Cancelable {
|
|
let run = new NukkitRunnable({ run: () => this.run(...args) })
|
|
let funcName = `runTask${this.interval ? 'Timer' : 'Later'}${this.isAsync ? 'Asynchronously' : ''}`
|
|
if (this.interval) {
|
|
run[funcName](this.plugin, this.laterTime, this.interval);
|
|
} else {
|
|
run[funcName](this.plugin, this.laterTime);
|
|
}
|
|
return run;
|
|
}
|
|
}
|