Spring 中的定时器的使用

public class SynContentTask extends TimerTask {
    private static Logger log = Logger.getLogger(SynContentTask.class);
    private ContentFacade contentFacade;

    public void setContentFacade(ContentFacade contentFacade) {
        this.contentFacade = contentFacade;
    }

    public void run() {
        log.debug("--- 定时任务开始扫描");
        // 查询待发布表
        List list = null;
        try {
            list = this.contentFacade.querySynTask();
        } catch (Exception e) {
            // TODO Auto-generated catch block
            log.error("--- 查询任务列表失败 ---");
            e.printStackTrace();
        }
        if (null != list) {
            log.debug("--- 获取同步任务，本次有 " + (list.size()) + " 个内容需要同步 ---");
            for (Iterator iter = list.iterator(); iter.hasNext();) {
                CtPubSynTaskVO task = (CtPubSynTaskVO) iter.next();
                try {
                    this.contentFacade.sendMsgToSms(task);
                } catch (Exception e) {
                    log.error("--- 同步内容：" + task.getContentId() + " 失败 ---");
                    e.printStackTrace();
                    continue;
                }
            }
        }

    }
}

spring配置

<bean id="synContentTask" class="syn.SynContentTask">
    <property name="contentFacade">
        <ref local="contentFacade"/>
    </property>
</bean>
<bean id="sheduledSynContentTask" class="org.springframework.scheduling.timer.ScheduledTimerTask">
    <property name="timerTask">
        <ref local="synContentTask"/>
    </property>
    <property name="period">
        <value>60000</value>
    </property>
    <property name="delay">
        <value>10000</value>
    </property>
</bean>
<bean class="org.springframework.scheduling.timer.TimerFactoryBean">
    <property name="scheduledTimerTasks">
        <list>
            <ref local="sheduledSynContentTask"/>
        </list>
    </property>
</bean>

评论

2 楼 jeasony 2009-05-18  

geeksun 写道

嗨  楼主  ContentFacade.java 的 querySynTask() 是同步方法吗？

只是举个例子，不是必须的

1 楼 geeksun 2009-05-12  

嗨  楼主  ContentFacade.java 的 querySynTask() 是同步方法吗？