Whenever we make an asynchronous method call, a thread will be dispatched. It
works well so far but we encountered serveral asynchronous call requirements
such as doing calculation when rolling over a day, sending reminder message for
a payment due, expiring a registration for certain condition. A scheduled task
might be cancelled in the middle, say, a payment made after the reminder
scheduled to send but before actually sending it.
Firstly we just simple make a asynchronous call when needed, but it turns out
there are too many threads running. We worry about the performance and
resources even though we haven't experienced them yet. We tried to make only
one asynchronous call with interval at every 5 minutes. The other scheduled
tasks are registered with it, and the tasks will mature within 5 minutes will
be dispatched with a one-off asynchronous call by this thread. The problem here
is that the one-off asynchronous calls run immidiately and the expiration or
duration totally get ignored. Thus the scheduled time might have discrepancy in
5 minutes.
Does Seam support to make an asynchronous call from another asynchronous call?
Or has anybody got another programming pattern to fulfill such kind of
requirements. In case I incorrently programmed the asynchronous feature, I
pasted the code below:
| //Making an asynchronous call to look after the other scheduled tasks
|
| @Name("scheduleDispatcherAction")
| @Scope(ScopeType.APPLICATION)
| @Synchronized
| @Startup
| public class ScheduleDispatcherAction implements ScheduleDispatcher,
Serializable {
|
| @In(create = true)
| private ScheduleService scheduleServiceAction;
|
| @Create
| public void startService() {
| ...
| scheduleServiceAction.dispatchTasks(cal.getTime(),
ScheduleService.INTERVAL_MILLIS);
|
| cal.add(Calendar.MINUTE, 1);
| ScheduledTask task = new ScheduledTask(new Long(1),
cal.getTime(), 45000, "miscAction", "test1", null);
| ScheduleServiceAction.addTask(task);
| cal.add(Calendar.MINUTE, 1);
| task = new ScheduledTask(new Long(2), cal.getTime(), 0,
"miscAction", "test2", null);
| ScheduleServiceAction.addTask(task);
| }
|
| //The method to dispatch the scheduled tasks
|
| @Name("scheduleServiceAction")
| @Scope(ScopeType.APPLICATION)
| @Synchronized
| public class ScheduleServiceAction implements ScheduleService, Serializable
{
|
| @Asynchronous
| public void dispatchTasks(@Expiration Date startDate, @IntervalDuration
long interval) {
| Iterator<ScheduledTask> iter = taskPool.iterator();
| while (iter.hasNext()) {
| ScheduledTask aTask = iter.next();
| long dueMillis = aTask.getStartDate().getTime() -
System.currentTimeMillis();
| if (dueMillis > ScheduleService.INTERVAL_MILLIS) {
| break;
| } else if (dueMillis < 0) {
| dueMillis = 0;
| }
|
| Object action =
Component.getInstance(aTask.getActionName(), ScopeType.APPLICATION);
| Method method =
action.getClass().getMethod(aTask.getMethodName(), new Class[]{long.class,
Object[].class});
| method.invoke(action, dueMillis, aTask.getParameters());
| // It's the same result if not using reflection here.
| ...
|
| //Task code
|
| @Name("miscAction")
| @Scope(ScopeType.APPLICATION)
| @Synchronized
| public class MiscAction implements MiscService, Serializable {
|
| @Asynchronous
| public void test1(@Duration long duration, Object[] paras) {;
| System.out.println("test1 started at " + (new Date()));
| }
|
| @Asynchronous
| public void test2(@Duration long duration, Object[] paras) {
| System.out.println("test2 started at " + (new Date()));
| }
|
View the original post :
http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4045329#4045329
Reply to the post :
http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4045329
_______________________________________________
jboss-user mailing list
jboss-user@lists.jboss.org
https://lists.jboss.org/mailman/listinfo/jboss-user
