Browse Source

Unified getServiceThreadPoolSize and getPostbackSenderPoolSize.

tags/1.0.2
Yuk-Ming Lam 4 years ago
parent
commit
4e0b471b8f
1 changed files with 4 additions and 7 deletions
  1. +4
    -7
      src/main/java/altk/comm/engine/Broadcast.java

+ 4
- 7
src/main/java/altk/comm/engine/Broadcast.java View File

@@ -72,7 +72,6 @@ public abstract class Broadcast
private int completedJobCount; private int completedJobCount;
private ScheduledExecutorService scheduler; private ScheduledExecutorService scheduler;
private int serviceThreadPoolSize_default;
private int jobsTotal; private int jobsTotal;
private int scheduledJobs; private int scheduledJobs;
@@ -415,7 +414,6 @@ public abstract class Broadcast
{ {
myLogger.debug("Entering Broadcast.doPost method"); myLogger.debug("Entering Broadcast.doPost method");
BroadcastException myException = null; BroadcastException myException = null;
serviceThreadPoolSize_default = commEngine.getServiceThreadPoolSize();
try try
{ {
boolean notInService = commEngine.notInService(); boolean notInService = commEngine.notInService();
@@ -492,7 +490,7 @@ public abstract class Broadcast
jobsTotal = recipientList.size(); jobsTotal = recipientList.size();
postback = new Postback(this, postback = new Postback(this,
commEngine.getPostbackMaxQueueSize(), commEngine.getPostbackMaxQueueSize(),
commEngine.getPostbackSenderPoolSize(),
getPostbackSenderPoolSize(),
commEngine.getPostbackMaxBatchSize()); commEngine.getPostbackMaxBatchSize());
// Create service thread pool to dispatch jobs, // Create service thread pool to dispatch jobs,
@@ -525,10 +523,9 @@ public abstract class Broadcast
} }
} }
protected int getServiceThreadPoolSize()
{
return serviceThreadPoolSize_default;
}
protected abstract int getServiceThreadPoolSize();
protected abstract int getPostbackSenderPoolSize();
protected abstract void returnPrerequisites(ServicePrerequisites prerequisites); protected abstract void returnPrerequisites(ServicePrerequisites prerequisites);


Loading…
Cancel
Save