View Javadoc

1   /**
2    *
3    * Copyright 2004 The Apache Software Foundation
4    *
5    *  Licensed under the Apache License, Version 2.0 (the "License");
6    *  you may not use this file except in compliance with the License.
7    *  You may obtain a copy of the License at
8    *
9    *     http://www.apache.org/licenses/LICENSE-2.0
10   *
11   *  Unless required by applicable law or agreed to in writing, software
12   *  distributed under the License is distributed on an "AS IS" BASIS,
13   *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14   *  See the License for the specific language governing permissions and
15   *  limitations under the License.
16   */
17  
18  package org.apache.geronimo.timer;
19  
20  import org.apache.commons.logging.Log;
21  import org.apache.commons.logging.LogFactory;
22  
23  /**
24   * @version $Rev: 430508 $ $Date: 2006-08-10 12:56:47 -0700 (Thu, 10 Aug 2006) $
25   */
26  public class NontransactionalExecutorTask implements ExecutorTask {
27  
28      private static final Log log = LogFactory.getLog(NontransactionalExecutorTask.class);
29  
30      private final Runnable userTask;
31      private final WorkInfo workInfo;
32      private final ThreadPooledTimer threadPooledTimer;
33  
34      public NontransactionalExecutorTask(Runnable userTask, WorkInfo workInfo, ThreadPooledTimer threadPooledTimer) {
35          this.userTask = userTask;
36          this.workInfo = workInfo;
37          this.threadPooledTimer = threadPooledTimer;
38      }
39  
40      public void run() {
41          try {
42              userTask.run();
43          } catch (Exception e) {
44              log.warn("Exception running task", e);
45          }
46          try {
47              threadPooledTimer.workPerformed(workInfo);
48          } catch (PersistenceException e) {
49              log.warn("Exception completing task", e);
50          }
51          if (workInfo.isOneTime()) {
52              threadPooledTimer.removeWorkInfo(workInfo);
53          }
54      }
55  }