ChunkThreadPoolExecutor class

Пакет: com.hypixel.hytale.server.worldgen.util

Файл: com/hypixel/hytale/server/worldgen/util/ChunkThreadPoolExecutor.java

extends: ThreadPoolExecutor

Поля (1)

МодификаторыТипИмя
final AtomicInteger GENERATION_COUNTER

Методы (1)

МодификаторыВозвратСигнатура
abstract super super(var1, var2, var3, var5, var6, var7)

Исходный код

Показать/скрыть
class="kw">package com.hypixel.hytale.server.worldgen.util;

class="kw">import java.util.concurrent.BlockingQueue;
class="kw">import java.util.concurrent.ThreadFactory;
class="kw">import java.util.concurrent.ThreadPoolExecutor;
class="kw">import java.util.concurrent.TimeUnit;
class="kw">import java.util.concurrent.atomic.AtomicInteger;
class="kw">import java.util.logging.Level;

class="kw">public class="kw">final class ChunkThreadPoolExecutor class="kw">extends ThreadPoolExecutor {
   class="kw">private class="kw">static class="kw">final AtomicInteger GENERATION_COUNTER = new AtomicInteger(0);
   class="kw">private class="kw">final int generation = GENERATION_COUNTER.getAndIncrement();
   class="kw">private class="kw">final Runnable shutdownHook;

   class="kw">public ChunkThreadPoolExecutor(int var1, int var2, long var3, TimeUnit var5, BlockingQueue<Runnable> var6, ThreadFactory var7, Runnable var8) {
      super(var1, var2, var3, var5, var6, var7);
      this.shutdownHook = var8;
      LogUtil.getLogger().at(Level.INFO).log("Initialized ChunkGenerator-%d executor", this.generation);
   }

   @Override
   class="kw">protected void terminated() {
      this.shutdownHook.run();
      LogUtil.getLogger().at(Level.INFO).log("ChunkGenerator-%d executor shutdown complete", this.generation);
   }
}