123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711 |
- package com.l2jserver.gameserver;
- import java.lang.Thread.UncaughtExceptionHandler;
- import java.util.concurrent.LinkedBlockingQueue;
- import java.util.concurrent.RejectedExecutionException;
- import java.util.concurrent.ScheduledFuture;
- import java.util.concurrent.ScheduledThreadPoolExecutor;
- import java.util.concurrent.ThreadFactory;
- import java.util.concurrent.ThreadPoolExecutor;
- import java.util.concurrent.TimeUnit;
- import java.util.concurrent.atomic.AtomicInteger;
- import org.slf4j.Logger;
- import org.slf4j.LoggerFactory;
- import com.l2jserver.Config;
- import com.l2jserver.util.StringUtil;
- public class ThreadPoolManager
- {
- protected static final Logger _log = LoggerFactory.getLogger(ThreadPoolManager.class);
-
- private static final class RunnableWrapper implements Runnable
- {
- private final Runnable _r;
-
- public RunnableWrapper(final Runnable r)
- {
- _r = r;
- }
-
- @Override
- public final void run()
- {
- try
- {
- _r.run();
- }
- catch (final Throwable e)
- {
- final Thread t = Thread.currentThread();
- final UncaughtExceptionHandler h = t.getUncaughtExceptionHandler();
- if (h != null)
- {
- h.uncaughtException(t, e);
- }
- }
- }
- }
-
- protected ScheduledThreadPoolExecutor _effectsScheduledThreadPool;
- protected ScheduledThreadPoolExecutor _generalScheduledThreadPool;
- protected ScheduledThreadPoolExecutor _aiScheduledThreadPool;
- protected ScheduledThreadPoolExecutor _eventScheduledThreadPool;
- private final ThreadPoolExecutor _generalPacketsThreadPool;
- private final ThreadPoolExecutor _ioPacketsThreadPool;
- private final ThreadPoolExecutor _generalThreadPool;
- private final ThreadPoolExecutor _eventThreadPool;
-
- private boolean _shutdown;
-
- public static ThreadPoolManager getInstance()
- {
- return SingletonHolder._instance;
- }
-
- protected ThreadPoolManager()
- {
- _effectsScheduledThreadPool = new ScheduledThreadPoolExecutor(Config.THREAD_P_EFFECTS, new PriorityThreadFactory("EffectsSTPool", Thread.NORM_PRIORITY));
- _generalScheduledThreadPool = new ScheduledThreadPoolExecutor(Config.THREAD_P_GENERAL, new PriorityThreadFactory("GeneralSTPool", Thread.NORM_PRIORITY));
- _eventScheduledThreadPool = new ScheduledThreadPoolExecutor(Config.THREAD_E_EVENTS, new PriorityThreadFactory("EventSTPool", Thread.NORM_PRIORITY));
- _ioPacketsThreadPool = new ThreadPoolExecutor(Config.IO_PACKET_THREAD_CORE_SIZE, Integer.MAX_VALUE, 5L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(), new PriorityThreadFactory("I/O Packet Pool", Thread.NORM_PRIORITY + 1));
- _generalPacketsThreadPool = new ThreadPoolExecutor(Config.GENERAL_PACKET_THREAD_CORE_SIZE, Config.GENERAL_PACKET_THREAD_CORE_SIZE + 2, 15L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(), new PriorityThreadFactory("Normal Packet Pool", Thread.NORM_PRIORITY + 1));
- _generalThreadPool = new ThreadPoolExecutor(Config.GENERAL_THREAD_CORE_SIZE, Config.GENERAL_THREAD_CORE_SIZE + 2, 5L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(), new PriorityThreadFactory("General Pool", Thread.NORM_PRIORITY));
- _aiScheduledThreadPool = new ScheduledThreadPoolExecutor(Config.AI_MAX_THREAD, new PriorityThreadFactory("AISTPool", Thread.NORM_PRIORITY));
- _eventThreadPool = new ThreadPoolExecutor(Config.EVENT_MAX_THREAD, Config.EVENT_MAX_THREAD + 2, 5L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(), new PriorityThreadFactory("Event Pool", Thread.NORM_PRIORITY));
-
- scheduleGeneralAtFixedRate(new PurgeTask(), 10, 5, TimeUnit.MINUTES);
- }
-
-
- public ScheduledFuture<?> scheduleEffect(Runnable task, long delay, TimeUnit unit)
- {
- try
- {
- return _effectsScheduledThreadPool.schedule(new RunnableWrapper(task), delay, unit);
- }
- catch (RejectedExecutionException e)
- {
- return null;
- }
- }
-
-
- public ScheduledFuture<?> scheduleEffect(Runnable task, long delay)
- {
- return scheduleEffect(task, delay, TimeUnit.MILLISECONDS);
- }
-
-
- public ScheduledFuture<?> scheduleEffectAtFixedRate(Runnable task, long initialDelay, long period, TimeUnit unit)
- {
- try
- {
- return _effectsScheduledThreadPool.scheduleAtFixedRate(new RunnableWrapper(task), initialDelay, period, unit);
- }
- catch (RejectedExecutionException e)
- {
- return null;
- }
- }
-
-
- public ScheduledFuture<?> scheduleEffectAtFixedRate(Runnable task, long initialDelay, long period)
- {
- return scheduleEffectAtFixedRate(task, initialDelay, period, TimeUnit.MILLISECONDS);
- }
-
-
- public ScheduledFuture<?> scheduleGeneral(Runnable task, long delay, TimeUnit unit)
- {
- try
- {
- return _generalScheduledThreadPool.schedule(new RunnableWrapper(task), delay, unit);
- }
- catch (RejectedExecutionException e)
- {
- return null;
- }
- }
-
-
- public ScheduledFuture<?> scheduleGeneral(Runnable task, long delay)
- {
- return scheduleGeneral(task, delay, TimeUnit.MILLISECONDS);
- }
-
-
- public ScheduledFuture<?> scheduleGeneralAtFixedRate(Runnable task, long initialDelay, long period, TimeUnit unit)
- {
- try
- {
- return _generalScheduledThreadPool.scheduleAtFixedRate(new RunnableWrapper(task), initialDelay, period, unit);
- }
- catch (RejectedExecutionException e)
- {
- return null;
- }
- }
-
-
- public ScheduledFuture<?> scheduleEvent(Runnable task, long delay, TimeUnit unit)
- {
- try
- {
- return _eventScheduledThreadPool.schedule(new RunnableWrapper(task), delay, unit);
- }
- catch (RejectedExecutionException e)
- {
- return null;
- }
- }
-
-
- public ScheduledFuture<?> scheduleEvent(Runnable task, long delay)
- {
- return scheduleEvent(task, delay, TimeUnit.MILLISECONDS);
- }
-
-
- public ScheduledFuture<?> scheduleEventAtFixedRate(Runnable task, long initialDelay, long period, TimeUnit unit)
- {
- try
- {
- return _eventScheduledThreadPool.scheduleAtFixedRate(new RunnableWrapper(task), initialDelay, period, unit);
- }
- catch (RejectedExecutionException e)
- {
- return null;
- }
- }
-
-
- public ScheduledFuture<?> scheduleGeneralAtFixedRate(Runnable task, long initialDelay, long period)
- {
- return scheduleGeneralAtFixedRate(task, initialDelay, period, TimeUnit.MILLISECONDS);
- }
-
-
- public ScheduledFuture<?> scheduleAi(Runnable task, long delay, TimeUnit unit)
- {
- try
- {
- return _aiScheduledThreadPool.schedule(new RunnableWrapper(task), delay, unit);
- }
- catch (RejectedExecutionException e)
- {
- return null;
- }
- }
-
-
- public ScheduledFuture<?> scheduleAi(Runnable task, long delay)
- {
- return scheduleAi(task, delay, TimeUnit.MILLISECONDS);
- }
-
-
- public ScheduledFuture<?> scheduleAiAtFixedRate(Runnable task, long initialDelay, long period, TimeUnit unit)
- {
- try
- {
- return _aiScheduledThreadPool.scheduleAtFixedRate(new RunnableWrapper(task), initialDelay, period, unit);
- }
- catch (RejectedExecutionException e)
- {
- return null;
- }
- }
-
-
- public ScheduledFuture<?> scheduleAiAtFixedRate(Runnable task, long initialDelay, long period)
- {
- return scheduleAiAtFixedRate(task, initialDelay, period, TimeUnit.MILLISECONDS);
- }
-
-
- public void executePacket(Runnable task)
- {
- try
- {
- _generalPacketsThreadPool.execute(task);
- }
- catch (RejectedExecutionException e)
- {
-
- }
- }
-
-
- public void executeIOPacket(Runnable task)
- {
- try
- {
- _ioPacketsThreadPool.execute(task);
- }
- catch (RejectedExecutionException e)
- {
-
- }
- }
-
-
- public void executeGeneral(Runnable task)
- {
- try
- {
- _generalThreadPool.execute(new RunnableWrapper(task));
- }
- catch (RejectedExecutionException e)
- {
-
- }
- }
-
-
- public void executeAi(Runnable task)
- {
- try
- {
- _aiScheduledThreadPool.execute(new RunnableWrapper(task));
- }
- catch (RejectedExecutionException e)
- {
-
- }
- }
-
-
- public void executeEvent(Runnable task)
- {
- try
- {
- _eventThreadPool.execute(new RunnableWrapper(task));
- }
- catch (RejectedExecutionException e)
- {
-
- }
- }
-
- public String[] getStats()
- {
- return new String[]
- {
- "STP:",
- " + Effects:",
- " |- ActiveThreads: " + _effectsScheduledThreadPool.getActiveCount(),
- " |- getCorePoolSize: " + _effectsScheduledThreadPool.getCorePoolSize(),
- " |- PoolSize: " + _effectsScheduledThreadPool.getPoolSize(),
- " |- MaximumPoolSize: " + _effectsScheduledThreadPool.getMaximumPoolSize(),
- " |- CompletedTasks: " + _effectsScheduledThreadPool.getCompletedTaskCount(),
- " |- ScheduledTasks: " + _effectsScheduledThreadPool.getQueue().size(),
- " | -------",
- " + General:",
- " |- ActiveThreads: " + _generalScheduledThreadPool.getActiveCount(),
- " |- getCorePoolSize: " + _generalScheduledThreadPool.getCorePoolSize(),
- " |- PoolSize: " + _generalScheduledThreadPool.getPoolSize(),
- " |- MaximumPoolSize: " + _generalScheduledThreadPool.getMaximumPoolSize(),
- " |- CompletedTasks: " + _generalScheduledThreadPool.getCompletedTaskCount(),
- " |- ScheduledTasks: " + _generalScheduledThreadPool.getQueue().size(),
- " | -------",
- " + AI:",
- " |- ActiveThreads: " + _aiScheduledThreadPool.getActiveCount(),
- " |- getCorePoolSize: " + _aiScheduledThreadPool.getCorePoolSize(),
- " |- PoolSize: " + _aiScheduledThreadPool.getPoolSize(),
- " |- MaximumPoolSize: " + _aiScheduledThreadPool.getMaximumPoolSize(),
- " |- CompletedTasks: " + _aiScheduledThreadPool.getCompletedTaskCount(),
- " |- ScheduledTasks: " + _aiScheduledThreadPool.getQueue().size(),
- " | -------",
- " + Event:",
- " |- ActiveThreads: " + _eventScheduledThreadPool.getActiveCount(),
- " |- getCorePoolSize: " + _eventScheduledThreadPool.getCorePoolSize(),
- " |- PoolSize: " + _eventScheduledThreadPool.getPoolSize(),
- " |- MaximumPoolSize: " + _eventScheduledThreadPool.getMaximumPoolSize(),
- " |- CompletedTasks: " + _eventScheduledThreadPool.getCompletedTaskCount(),
- " |- ScheduledTasks: " + _eventScheduledThreadPool.getQueue().size(),
- "TP:",
- " + Packets:",
- " |- ActiveThreads: " + _generalPacketsThreadPool.getActiveCount(),
- " |- getCorePoolSize: " + _generalPacketsThreadPool.getCorePoolSize(),
- " |- MaximumPoolSize: " + _generalPacketsThreadPool.getMaximumPoolSize(),
- " |- LargestPoolSize: " + _generalPacketsThreadPool.getLargestPoolSize(),
- " |- PoolSize: " + _generalPacketsThreadPool.getPoolSize(),
- " |- CompletedTasks: " + _generalPacketsThreadPool.getCompletedTaskCount(),
- " |- QueuedTasks: " + _generalPacketsThreadPool.getQueue().size(),
- " | -------",
- " + I/O Packets:",
- " |- ActiveThreads: " + _ioPacketsThreadPool.getActiveCount(),
- " |- getCorePoolSize: " + _ioPacketsThreadPool.getCorePoolSize(),
- " |- MaximumPoolSize: " + _ioPacketsThreadPool.getMaximumPoolSize(),
- " |- LargestPoolSize: " + _ioPacketsThreadPool.getLargestPoolSize(),
- " |- PoolSize: " + _ioPacketsThreadPool.getPoolSize(),
- " |- CompletedTasks: " + _ioPacketsThreadPool.getCompletedTaskCount(),
- " |- QueuedTasks: " + _ioPacketsThreadPool.getQueue().size(),
- " | -------",
- " + General Tasks:",
- " |- ActiveThreads: " + _generalThreadPool.getActiveCount(),
- " |- getCorePoolSize: " + _generalThreadPool.getCorePoolSize(),
- " |- MaximumPoolSize: " + _generalThreadPool.getMaximumPoolSize(),
- " |- LargestPoolSize: " + _generalThreadPool.getLargestPoolSize(),
- " |- PoolSize: " + _generalThreadPool.getPoolSize(),
- " |- CompletedTasks: " + _generalThreadPool.getCompletedTaskCount(),
- " |- QueuedTasks: " + _generalThreadPool.getQueue().size(),
- " | -------",
- " + Event Tasks:",
- " |- ActiveThreads: " + _eventThreadPool.getActiveCount(),
- " |- getCorePoolSize: " + _eventThreadPool.getCorePoolSize(),
- " |- MaximumPoolSize: " + _eventThreadPool.getMaximumPoolSize(),
- " |- LargestPoolSize: " + _eventThreadPool.getLargestPoolSize(),
- " |- PoolSize: " + _eventThreadPool.getPoolSize(),
- " |- CompletedTasks: " + _eventThreadPool.getCompletedTaskCount(),
- " |- QueuedTasks: " + _eventThreadPool.getQueue().size(),
- " | -------"
- };
- }
-
- private static class PriorityThreadFactory implements ThreadFactory
- {
- private final int _prio;
- private final String _name;
- private final AtomicInteger _threadNumber = new AtomicInteger(1);
- private final ThreadGroup _group;
-
- public PriorityThreadFactory(String name, int prio)
- {
- _prio = prio;
- _name = name;
- _group = new ThreadGroup(_name);
- }
-
- @Override
- public Thread newThread(Runnable r)
- {
- Thread t = new Thread(_group, r, _name + "-" + _threadNumber.getAndIncrement());
- t.setPriority(_prio);
- return t;
- }
-
- public ThreadGroup getGroup()
- {
- return _group;
- }
- }
-
- public void shutdown()
- {
- _shutdown = true;
- try
- {
- _effectsScheduledThreadPool.awaitTermination(1, TimeUnit.SECONDS);
- _generalScheduledThreadPool.awaitTermination(1, TimeUnit.SECONDS);
- _generalPacketsThreadPool.awaitTermination(1, TimeUnit.SECONDS);
- _ioPacketsThreadPool.awaitTermination(1, TimeUnit.SECONDS);
- _generalThreadPool.awaitTermination(1, TimeUnit.SECONDS);
- _eventThreadPool.awaitTermination(1, TimeUnit.SECONDS);
- _effectsScheduledThreadPool.shutdown();
- _generalScheduledThreadPool.shutdown();
- _generalPacketsThreadPool.shutdown();
- _ioPacketsThreadPool.shutdown();
- _generalThreadPool.shutdown();
- _eventThreadPool.shutdown();
- _log.info("All ThreadPools are now stopped");
-
- }
- catch (InterruptedException e)
- {
- _log.warn("There has been a problem shuting down the thread pool manager!", e);
- }
- }
-
- public boolean isShutdown()
- {
- return _shutdown;
- }
-
- public void purge()
- {
- _effectsScheduledThreadPool.purge();
- _generalScheduledThreadPool.purge();
- _aiScheduledThreadPool.purge();
- _eventScheduledThreadPool.purge();
- _ioPacketsThreadPool.purge();
- _generalPacketsThreadPool.purge();
- _generalThreadPool.purge();
- _eventThreadPool.purge();
- }
-
- public String getPacketStats()
- {
- final StringBuilder sb = new StringBuilder(1000);
- ThreadFactory tf = _generalPacketsThreadPool.getThreadFactory();
- if (tf instanceof PriorityThreadFactory)
- {
- PriorityThreadFactory ptf = (PriorityThreadFactory) tf;
- int count = ptf.getGroup().activeCount();
- Thread[] threads = new Thread[count + 2];
- ptf.getGroup().enumerate(threads);
- StringUtil.append(sb, "General Packet Thread Pool:" + Config.EOL + "Tasks in the queue: ", String.valueOf(_generalPacketsThreadPool.getQueue().size()), Config.EOL + "Showing threads stack trace:" + Config.EOL + "There should be ", String.valueOf(count), " Threads" + Config.EOL);
- for (Thread t : threads)
- {
- if (t == null)
- {
- continue;
- }
-
- StringUtil.append(sb, t.getName(), Config.EOL);
- for (StackTraceElement ste : t.getStackTrace())
- {
- StringUtil.append(sb, ste.toString(), Config.EOL);
- }
- }
- }
-
- sb.append("Packet Tp stack traces printed.");
- sb.append(Config.EOL);
- return sb.toString();
- }
-
- public String getIOPacketStats()
- {
- final StringBuilder sb = new StringBuilder(1000);
- ThreadFactory tf = _ioPacketsThreadPool.getThreadFactory();
-
- if (tf instanceof PriorityThreadFactory)
- {
- PriorityThreadFactory ptf = (PriorityThreadFactory) tf;
- int count = ptf.getGroup().activeCount();
- Thread[] threads = new Thread[count + 2];
- ptf.getGroup().enumerate(threads);
- StringUtil.append(sb, "I/O Packet Thread Pool:" + Config.EOL + "Tasks in the queue: ", String.valueOf(_ioPacketsThreadPool.getQueue().size()), Config.EOL + "Showing threads stack trace:" + Config.EOL + "There should be ", String.valueOf(count), " Threads" + Config.EOL);
-
- for (Thread t : threads)
- {
- if (t == null)
- {
- continue;
- }
-
- StringUtil.append(sb, t.getName(), Config.EOL);
-
- for (StackTraceElement ste : t.getStackTrace())
- {
- StringUtil.append(sb, ste.toString(), Config.EOL);
- }
- }
- }
-
- sb.append("Packet Tp stack traces printed." + Config.EOL);
-
- return sb.toString();
- }
-
- public String getGeneralStats()
- {
- final StringBuilder sb = new StringBuilder(1000);
- ThreadFactory tf = _generalThreadPool.getThreadFactory();
-
- if (tf instanceof PriorityThreadFactory)
- {
- PriorityThreadFactory ptf = (PriorityThreadFactory) tf;
- int count = ptf.getGroup().activeCount();
- Thread[] threads = new Thread[count + 2];
- ptf.getGroup().enumerate(threads);
- StringUtil.append(sb, "General Thread Pool:" + Config.EOL + "Tasks in the queue: ", String.valueOf(_generalThreadPool.getQueue().size()), Config.EOL + "Showing threads stack trace:" + Config.EOL + "There should be ", String.valueOf(count), " Threads" + Config.EOL);
-
- for (Thread t : threads)
- {
- if (t == null)
- {
- continue;
- }
-
- StringUtil.append(sb, t.getName(), Config.EOL);
-
- for (StackTraceElement ste : t.getStackTrace())
- {
- StringUtil.append(sb, ste.toString(), Config.EOL);
- }
- }
- }
-
- sb.append("Packet Tp stack traces printed." + Config.EOL);
-
- return sb.toString();
- }
-
- protected class PurgeTask implements Runnable
- {
- @Override
- public void run()
- {
- _effectsScheduledThreadPool.purge();
- _generalScheduledThreadPool.purge();
- _aiScheduledThreadPool.purge();
- _eventScheduledThreadPool.purge();
- }
- }
-
- private static class SingletonHolder
- {
- protected static final ThreadPoolManager _instance = new ThreadPoolManager();
- }
- }
|