jack_a1SCS
  1.   BukkitTask aa= Bukkit.getScheduler().runTaskTimerAsynchronously(ZhiWumian.plugin,()->{
  2.             Savezhiwudate.save();
  3.         },0,ZhiWumian.plugin.getConfig().getLong("savetime")*20*60); 这种异步算分支线程还是主线程啊
复制代码

3TUSK
Asynchronous tasks should never access any API in Bukkit. Great care should be taken to assure the thread-safety of asynchronous tasks.
Returns a task that will repeatedly run asynchronously until cancelled, starting after the specified number of server ticks.
——https://hub.spigotmc.org/javadoc ... TimerAsynchronously(org.bukkit.plugin.Plugin,java.lang.Runnable,long,long)


Javadoc 并没有说明是异步单线程还是异步多线程，但就「不要访问 Bukkit API」这个说法来看，应该是异步多线程。
吕易天
本帖最后由 吕易天 于 2021-6-19 10:07 编辑

Async任务不是在主线程执行的
org.bukkit.craftbukkit.xxx.scheduler.CraftScheduler.java:
  1.     @Override
  2.     public BukkitTask runTaskTimerAsynchronously(Plugin plugin, Runnable runnable, long delay, long period) {
  3.         CraftScheduler.validate(plugin, runnable);
  4.         if (delay < 0L) {
  5.             delay = 0L;
  6.         }
  7.         if (period == 0L) {
  8.             period = 1L;
  9.         } else if (period < -1L) {
  10.             period = -1L;
  11.         }
  12.         return this.handle(new CraftAsyncTask(this.asyncScheduler.runners, plugin, runnable, this.nextId(), period), delay);
  13.     }
  14.     protected CraftTask handle(CraftTask task, long delay) {
  15.         if (!this.isAsyncScheduler && !task.isSync()) {
  16.             this.asyncScheduler.handle(task, delay);
  17.             return task;
  18.         }
  19.         task.setNextRun((long)this.currentTick + delay);
  20.         this.addTask(task);
  21.         return task;
  22.     }
  23.     protected void addTask(CraftTask task) {
  24.         AtomicReference<CraftTask> tail = this.tail;
  25.         CraftTask tailTask = tail.get();
  26.         while (!tail.compareAndSet(tailTask, task)) {
  27.             tailTask = tail.get();
  28.         }
  29.         tailTask.setNext(task);
  30.     }
复制代码

org.bukkit.craftbukkit.xxx.scheduler.CraftAsyncScheduler.java:
  1. private final ThreadPoolExecutor executor = new ThreadPoolExecutor(4, Integer.MAX_VALUE, 30L, TimeUnit.SECONDS, new SynchronousQueue<Runnable>(), new ThreadFactoryBuilder().setNameFormat("Craft Scheduler Thread - %1$d").build());
  2.     private final Executor management = Executors.newSingleThreadExecutor(new ThreadFactoryBuilder().setNameFormat("Craft Async Scheduler Management Thread").build());
  3.     private final List<CraftTask> temp = new ArrayList<CraftTask>();

  5. @Override
  6.     public void mainThreadHeartbeat(int currentTick) {
  7.         this.currentTick = currentTick;
  8.         this.management.execute(() -> this.runTasks(currentTick));
  9.     }

  11.     private synchronized void runTasks(int currentTick) {
  12.         this.parsePending();
  13.         while (!this.pending.isEmpty() && ((CraftTask)this.pending.peek()).getNextRun() <= (long)currentTick) {
  14.             long period;
  15.             CraftTask task = (CraftTask)this.pending.remove();
  16.             if (this.executeTask(task) && (period = task.getPeriod()) > 0L) {
  17.                 task.setNextRun((long)currentTick + period);
  18.                 this.temp.add(task);
  19.             }
  20.             this.parsePending();
  21.         }
  22.         this.pending.addAll(this.temp);
  23.         this.temp.clear();
  24.     }

  26.     private boolean executeTask(CraftTask task) {
  27.         if (CraftAsyncScheduler.isValid(task)) {
  28.             this.runners.put(task.getTaskId(), task);
  29.             this.executor.execute(new ServerSchedulerReportingWrapper(task));
  30.             return true;
  31.         }
  32.         return false;
  33.     }
复制代码


可见它用了线程池来执行任务

第一页 上一页 下一页 最后一页