Commit 6eaa004b authored by liujiahua123123's avatar liujiahua123123

rename

parent e85014e7
package net.mamoe.mirai.task; package net.mamoe.mirai.task;
@FunctionalInterface @FunctionalInterface
public interface MiralTaskExceptionHandler { public interface MiraiTaskExceptionHandler {
void onHandle(Throwable e); void onHandle(Throwable e);
static MiralTaskExceptionHandler byDefault(){ static MiraiTaskExceptionHandler byDefault(){
return Throwable::printStackTrace; return Throwable::printStackTrace;
} }
} }
package net.mamoe.mirai.task; package net.mamoe.mirai.task;
import lombok.Getter;
import net.mamoe.mirai.MiraiServer; import net.mamoe.mirai.MiraiServer;
import net.mamoe.mirai.event.events.server.ServerDisableEvent; import net.mamoe.mirai.event.events.server.ServerDisableEvent;
...@@ -36,10 +35,10 @@ public class MiraiTaskManager { ...@@ -36,10 +35,10 @@ public class MiraiTaskManager {
*/ */
public void execute(Runnable runnable){ public void execute(Runnable runnable){
this.execute(runnable,MiralTaskExceptionHandler.byDefault()); this.execute(runnable, MiraiTaskExceptionHandler.byDefault());
} }
public void execute(Runnable runnable, MiralTaskExceptionHandler handler){ public void execute(Runnable runnable, MiraiTaskExceptionHandler handler){
this.pool.execute(() -> this.pool.execute(() ->
{ {
try{ try{
...@@ -52,10 +51,10 @@ public class MiraiTaskManager { ...@@ -52,10 +51,10 @@ public class MiraiTaskManager {
public <D> Future<D> submit(Callable<D> callable) { public <D> Future<D> submit(Callable<D> callable) {
return this.submit(callable, MiralTaskExceptionHandler.byDefault()); return this.submit(callable, MiraiTaskExceptionHandler.byDefault());
} }
public <D> Future<D> submit(Callable<D> callable, MiralTaskExceptionHandler handler) { public <D> Future<D> submit(Callable<D> callable, MiraiTaskExceptionHandler handler) {
return this.pool.submit(() -> { return this.pool.submit(() -> {
try { try {
return callable.call(); return callable.call();
...@@ -70,10 +69,10 @@ public class MiraiTaskManager { ...@@ -70,10 +69,10 @@ public class MiraiTaskManager {
异步任务 异步任务
*/ */
public <D> void ansycTask(Callable<D> callable, Consumer<D> callback){ public <D> void ansycTask(Callable<D> callable, Consumer<D> callback){
this.ansycTask(callable,callback,MiralTaskExceptionHandler.byDefault()); this.ansycTask(callable,callback, MiraiTaskExceptionHandler.byDefault());
} }
public <D> void ansycTask(Callable<D> callable, Consumer<D> callback, MiralTaskExceptionHandler handler){ public <D> void ansycTask(Callable<D> callable, Consumer<D> callback, MiraiTaskExceptionHandler handler){
this.pool.execute(() -> { this.pool.execute(() -> {
try { try {
callback.accept(callable.call()); callback.accept(callable.call());
...@@ -88,25 +87,25 @@ public class MiraiTaskManager { ...@@ -88,25 +87,25 @@ public class MiraiTaskManager {
*/ */
public void repeatingTask(Runnable runnable, long interval){ public void repeatingTask(Runnable runnable, long interval){
this.repeatingTask(runnable,interval, MiralTaskExceptionHandler.byDefault()); this.repeatingTask(runnable,interval, MiraiTaskExceptionHandler.byDefault());
} }
public void repeatingTask(Runnable runnable, long interval, MiralTaskExceptionHandler handler){ public void repeatingTask(Runnable runnable, long interval, MiraiTaskExceptionHandler handler){
this.repeatingTask(runnable,interval,a -> true,handler); this.repeatingTask(runnable,interval,a -> true,handler);
} }
public void repeatingTask(Runnable runnable, long interval, int times){ public void repeatingTask(Runnable runnable, long interval, int times){
this.repeatingTask(runnable,interval,times,MiralTaskExceptionHandler.byDefault()); this.repeatingTask(runnable,interval,times, MiraiTaskExceptionHandler.byDefault());
} }
public void repeatingTask(Runnable runnable, long interval, int times, MiralTaskExceptionHandler handler){ public void repeatingTask(Runnable runnable, long interval, int times, MiraiTaskExceptionHandler handler){
AtomicInteger integer = new AtomicInteger(times); AtomicInteger integer = new AtomicInteger(times);
this.repeatingTask( this.repeatingTask(
runnable,interval, a -> integer.getAndDecrement() > 0, handler runnable,interval, a -> integer.getAndDecrement() > 0, handler
); );
} }
public <D extends Runnable> void repeatingTask(D runnable, long interval, Predicate<D> shouldContinue, MiralTaskExceptionHandler handler){ public <D extends Runnable> void repeatingTask(D runnable, long interval, Predicate<D> shouldContinue, MiraiTaskExceptionHandler handler){
new Thread(() -> { new Thread(() -> {
do { do {
this.pool.execute(() -> { this.pool.execute(() -> {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment