package l2ft.gameserver;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import l2ft.commons.threading.LoggingRejectedExecutionHandler;
import l2ft.commons.threading.PriorityThreadFactory;
import l2ft.commons.threading.RunnableImpl;
import l2ft.commons.threading.RunnableStatsWrapper;
public class ThreadPoolManager
{
private static final long MAX_DELAY = TimeUnit.NANOSECONDS.toMillis(Long.MAX_VALUE - System.nanoTime()) / 2;
private static final ThreadPoolManager _instance = new ThreadPoolManager();
public static ThreadPoolManager getInstance()
{
return _instance;
}
private final ScheduledThreadPoolExecutor _scheduledExecutor;
private final ThreadPoolExecutor _executor;
private boolean _shutdown;
private ThreadPoolManager()
{
_scheduledExecutor = new ScheduledThreadPoolExecutor(Config.SCHEDULED_THREAD_POOL_SIZE, new PriorityThreadFactory("ScheduledThreadPool", Thread.NORM_PRIORITY), new LoggingRejectedExecutionHandler());
_executor = new ThreadPoolExecutor(Config.EXECUTOR_THREAD_POOL_SIZE, Integer.MAX_VALUE, 5L, TimeUnit.SECONDS, new LinkedBlockingQueue(), new PriorityThreadFactory("ThreadPoolExecutor", Thread.NORM_PRIORITY), new LoggingRejectedExecutionHandler());
//Очистка каждые 5 минут
scheduleAtFixedRate(new RunnableImpl()
{
@Override
public void runImpl()
{
_scheduledExecutor.purge();
_executor.purge();
}
}, 300000L, 300000L);
}
private long validate(long delay)
{
return Math.max(0, Math.min(MAX_DELAY, delay));
}
public boolean isShutdown()
{
return _shutdown;
}
public Runnable wrap(Runnable r)
{
return Config.ENABLE_RUNNABLE_STATS ? RunnableStatsWrapper.wrap® : r;
}
public ScheduledFutureschedule(Runnable r, long delay)
{
return _scheduledExecutor.schedule(wrap®, validate(delay), TimeUnit.MILLISECONDS);
}
public ScheduledFuturescheduleAtFixedRate(Runnable r, long initial, long delay)
{
return _scheduledExecutor.scheduleAtFixedRate(wrap®, validate(initial), validate(delay), TimeUnit.MILLISECONDS);
}
public ScheduledFuturescheduleAtFixedDelay(Runnable r, long initial, long delay)
{
return _scheduledExecutor.scheduleWithFixedDelay(wrap®, validate(initial), validate(delay), TimeUnit.MILLISECONDS);
}
public void execute(Runnable r)
{
_executor.execute(wrap®);
}
public void shutdown() throws InterruptedException
{
_shutdown = true;
try
{
_scheduledExecutor.shutdown();
_scheduledExecutor.awaitTermination(10, TimeUnit.SECONDS);
}
finally
{
_executor.shutdown();
_executor.awaitTermination(1, TimeUnit.MINUTES);
}
}
public CharSequence getStats()
{
StringBuilder list = new StringBuilder();
list.append("ScheduledThreadPool\n");
list.append("=================================================\n");
list.append("\tgetActiveCount: ...... ").append(_scheduledExecutor.getActiveCount()).append("\n");
list.append("\tgetCorePoolSize: ..... ").append(_scheduledExecutor.getCorePoolSize()).append("\n");
list.append("\tgetPoolSize: ......... ").append(_scheduledExecutor.getPoolSize()).append("\n");
list.append("\tgetLargestPoolSize: .. ").append(_scheduledExecutor.getLargestPoolSize()).append("\n");
list.append("\tgetMaximumPoolSize: .. ").append(_scheduledExecutor.getMaximumPoolSize()).append("\n");
list.append("\tgetCompletedTaskCount: ").append(_scheduledExecutor.getCompletedTaskCount()).append("\n");
list.append("\tgetQueuedTaskCount: .. ").append(_scheduledExecutor.getQueue().size()).append("\n");
list.append("\tgetTaskCount: ........ ").append(_scheduledExecutor.getTaskCount()).append("\n");
list.append("ThreadPoolExecutor\n");
list.append("=================================================\n");
list.append("\tgetActiveCount: ...... ").append(_executor.getActiveCount()).append("\n");
list.append("\tgetCorePoolSize: ..... ").append(_executor.getCorePoolSize()).append("\n");
list.append("\tgetPoolSize: ......... ").append(_executor.getPoolSize()).append("\n");
list.append("\tgetLargestPoolSize: .. ").append(_executor.getLargestPoolSize()).append("\n");
list.append("\tgetMaximumPoolSize: .. ").append(_executor.getMaximumPoolSize()).append("\n");
list.append("\tgetCompletedTaskCount: ").append(_executor.getCompletedTaskCount()).append("\n");
list.append("\tgetQueuedTaskCount: .. ").append(_executor.getQueue().size()).append("\n");
list.append("\tgetTaskCount: ........ ").append(_executor.getTaskCount()).append("\n");
return list;
}
}
