lineage2/l2j_mobius
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Canceled tasks should be immediately removed from the work queue at time of cancellation.

Browse Source
This commit is contained in:
MobiusDevelopment
2019-05-17 00:20:38 +00:00
parent 77e5379d97
commit 71568c1a02
14 changed files with 14 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
L2J_Mobius_1.0_Ertheia/java/org/l2jmobius/commons/concurrent/ThreadPool.java
View File

@@ -62,6 +62,7 @@ public final class ThreadPool
for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS) for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS)
{ {
threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl()); threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl());
threadPool.setRemoveOnCancelPolicy(true);
threadPool.prestartAllCoreThreads(); threadPool.prestartAllCoreThreads();
} }
for (ThreadPoolExecutor threadPool : INSTANT_POOLS) for (ThreadPoolExecutor threadPool : INSTANT_POOLS)

1
L2J_Mobius_2.5_Underground/java/org/l2jmobius/commons/concurrent/ThreadPool.java
View File

@@ -62,6 +62,7 @@ public final class ThreadPool
for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS) for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS)
{ {
threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl()); threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl());
threadPool.setRemoveOnCancelPolicy(true);
threadPool.prestartAllCoreThreads(); threadPool.prestartAllCoreThreads();
} }
for (ThreadPoolExecutor threadPool : INSTANT_POOLS) for (ThreadPoolExecutor threadPool : INSTANT_POOLS)

1
L2J_Mobius_3.0_Helios/java/org/l2jmobius/commons/concurrent/ThreadPool.java
View File

@@ -62,6 +62,7 @@ public final class ThreadPool
for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS) for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS)
{ {
threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl()); threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl());
threadPool.setRemoveOnCancelPolicy(true);
threadPool.prestartAllCoreThreads(); threadPool.prestartAllCoreThreads();
} }
for (ThreadPoolExecutor threadPool : INSTANT_POOLS) for (ThreadPoolExecutor threadPool : INSTANT_POOLS)

1
L2J_Mobius_4.0_GrandCrusade/java/org/l2jmobius/commons/concurrent/ThreadPool.java
View File

@@ -62,6 +62,7 @@ public final class ThreadPool
for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS) for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS)
{ {
threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl()); threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl());
threadPool.setRemoveOnCancelPolicy(true);
threadPool.prestartAllCoreThreads(); threadPool.prestartAllCoreThreads();
} }
for (ThreadPoolExecutor threadPool : INSTANT_POOLS) for (ThreadPoolExecutor threadPool : INSTANT_POOLS)

1
L2J_Mobius_5.0_Salvation/java/org/l2jmobius/commons/concurrent/ThreadPool.java
View File

@@ -62,6 +62,7 @@ public final class ThreadPool
for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS) for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS)
{ {
threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl()); threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl());
threadPool.setRemoveOnCancelPolicy(true);
threadPool.prestartAllCoreThreads(); threadPool.prestartAllCoreThreads();
} }
for (ThreadPoolExecutor threadPool : INSTANT_POOLS) for (ThreadPoolExecutor threadPool : INSTANT_POOLS)

1
L2J_Mobius_5.5_EtinasFate/java/org/l2jmobius/commons/concurrent/ThreadPool.java
View File

@@ -62,6 +62,7 @@ public final class ThreadPool
for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS) for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS)
{ {
threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl()); threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl());
threadPool.setRemoveOnCancelPolicy(true);
threadPool.prestartAllCoreThreads(); threadPool.prestartAllCoreThreads();
} }
for (ThreadPoolExecutor threadPool : INSTANT_POOLS) for (ThreadPoolExecutor threadPool : INSTANT_POOLS)

1
L2J_Mobius_6.0_Fafurion/java/org/l2jmobius/commons/concurrent/ThreadPool.java
View File

@@ -62,6 +62,7 @@ public final class ThreadPool
for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS) for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS)
{ {
threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl()); threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl());
threadPool.setRemoveOnCancelPolicy(true);
threadPool.prestartAllCoreThreads(); threadPool.prestartAllCoreThreads();
} }
for (ThreadPoolExecutor threadPool : INSTANT_POOLS) for (ThreadPoolExecutor threadPool : INSTANT_POOLS)

1
L2J_Mobius_C6_Interlude/java/org/l2jmobius/commons/concurrent/ThreadPool.java
View File

@@ -62,6 +62,7 @@ public final class ThreadPool
for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS) for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS)
{ {
threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl()); threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl());
threadPool.setRemoveOnCancelPolicy(true);
threadPool.prestartAllCoreThreads(); threadPool.prestartAllCoreThreads();
} }
for (ThreadPoolExecutor threadPool : INSTANT_POOLS) for (ThreadPoolExecutor threadPool : INSTANT_POOLS)

1
L2J_Mobius_CT_2.6_HighFive/java/org/l2jmobius/commons/concurrent/ThreadPool.java
View File

@@ -62,6 +62,7 @@ public final class ThreadPool
for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS) for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS)
{ {
threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl()); threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl());
threadPool.setRemoveOnCancelPolicy(true);
threadPool.prestartAllCoreThreads(); threadPool.prestartAllCoreThreads();
} }
for (ThreadPoolExecutor threadPool : INSTANT_POOLS) for (ThreadPoolExecutor threadPool : INSTANT_POOLS)

1
L2J_Mobius_Classic_2.0_Saviors/java/org/l2jmobius/commons/concurrent/ThreadPool.java
View File

@@ -62,6 +62,7 @@ public final class ThreadPool
for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS) for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS)
{ {
threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl()); threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl());
threadPool.setRemoveOnCancelPolicy(true);
threadPool.prestartAllCoreThreads(); threadPool.prestartAllCoreThreads();
} }
for (ThreadPoolExecutor threadPool : INSTANT_POOLS) for (ThreadPoolExecutor threadPool : INSTANT_POOLS)

1
L2J_Mobius_Classic_2.1_Zaken/java/org/l2jmobius/commons/concurrent/ThreadPool.java
View File

@@ -62,6 +62,7 @@ public final class ThreadPool
for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS) for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS)
{ {
threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl()); threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl());
threadPool.setRemoveOnCancelPolicy(true);
threadPool.prestartAllCoreThreads(); threadPool.prestartAllCoreThreads();
} }
for (ThreadPoolExecutor threadPool : INSTANT_POOLS) for (ThreadPoolExecutor threadPool : INSTANT_POOLS)

1
L2J_Mobius_Classic_2.2_Antharas/java/org/l2jmobius/commons/concurrent/ThreadPool.java
View File

@@ -62,6 +62,7 @@ public final class ThreadPool
for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS) for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS)
{ {
threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl()); threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl());
threadPool.setRemoveOnCancelPolicy(true);
threadPool.prestartAllCoreThreads(); threadPool.prestartAllCoreThreads();
} }
for (ThreadPoolExecutor threadPool : INSTANT_POOLS) for (ThreadPoolExecutor threadPool : INSTANT_POOLS)

1
L2J_Mobius_Classic_2.3_SevenSigns/java/org/l2jmobius/commons/concurrent/ThreadPool.java
View File

@@ -62,6 +62,7 @@ public final class ThreadPool
for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS) for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS)
{ {
threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl()); threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl());
threadPool.setRemoveOnCancelPolicy(true);
threadPool.prestartAllCoreThreads(); threadPool.prestartAllCoreThreads();
} }
for (ThreadPoolExecutor threadPool : INSTANT_POOLS) for (ThreadPoolExecutor threadPool : INSTANT_POOLS)

1
L2J_Mobius_Classic_2.4_SecretOfEmpire/java/org/l2jmobius/commons/concurrent/ThreadPool.java
View File

@@ -62,6 +62,7 @@ public final class ThreadPool
for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS) for (ScheduledThreadPoolExecutor threadPool : SCHEDULED_POOLS)
{ {
threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl()); threadPool.setRejectedExecutionHandler(new RejectedExecutionHandlerImpl());
threadPool.setRemoveOnCancelPolicy(true);
threadPool.prestartAllCoreThreads(); threadPool.prestartAllCoreThreads();
} }
for (ThreadPoolExecutor threadPool : INSTANT_POOLS) for (ThreadPoolExecutor threadPool : INSTANT_POOLS)