补充---spring多线程任务调度

<!-- 接收数据 -->
    <!-- 异步线程池 -->
    <bean id="threadPool" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
    <!-- 核心线程数  -->
    <property name="corePoolSize" value="10" />
    <!-- 最大线程数 -->
    <property name="maxPoolSize" value="100" />
    <!-- 队列最大长度 >=mainExecutor.maxSize -->
    <property name="queueCapacity" value="1000" />
    <!-- 线程池维护线程所允许的空闲时间 -->
    <property name="keepAliveSeconds" value="300" />
    <!-- 线程池对拒绝任务(无线程可用)的处理策略 -->
    <property name="rejectedExecutionHandler">
        <bean class="java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy" />
    </property>
    </bean>
    
    <bean id="collectSalesOrderExecutor" class="com.fts.internal.CollectSalesOrderExecutor">
        <property name="threadPool" ref="threadPool" />
        <property name="dataSource" ref="dataSource" />
    </bean>
    
    <bean id="springScheduleExecutorTask" class="org.springframework.scheduling.concurrent.ScheduledExecutorTask">
        <property name="runnable" ref="collectSalesOrderExecutor" />
        <!-- 容器加载10秒后开始执行 -->
        <property name="delay" value="10000" />
        <!-- 每次任务间隔 30秒-->
        <property name="period" value="30000" />
        
    </bean>
    
    <bean id="springScheduledExecutorFactoryBean" class="org.springframework.scheduling.concurrent.ScheduledExecutorFactoryBean">
        <property name="scheduledExecutorTasks" >
        <list>
            <ref bean="springScheduleExecutorTask" />
        </list>

        </property> 
    </bean>

public class CollectSalesOrderExecutor extends TimerTask {

    //注入ThreadPoolTaskExecutor 到主线程中
    private ThreadPoolTaskExecutor threadPool;
    private JdbcTemplate template;
    
    public void setThreadPool(ThreadPoolTaskExecutor threadPool) {
        this.threadPool = threadPool;
    }
    
    //注入数据源
    public void setDataSource(DataSource dataSource) {
        this.template = new JdbcTemplate(dataSource);
    }

    @Override
    public void run() {
        System.out.format("开始执行 %s ...%n", new Date());
        @SuppressWarnings("unchecked")
        //取得设备列表
        List<Equipment> ipList = template.query("select e.* from equipment e ", ParameterizedBeanPropertyRowMapper.newInstance(Equipment.class));
        if (ipList != null) {
            for (Equipment equipment : ipList) {
                try {
                    //执行向各个设备采集数据并保存数据库
                    threadPool.execute(new CollectSalesOrderTask(template,equipment.getIp()));
                } catch (Exception ex) {
                    ex.printStackTrace();
                }
            }
        }

    }

} 

public class CollectSalesOrderTask implements Runnable {
    private String ip;
    private JdbcTemplate template;

    public CollectSalesOrderTask(JdbcTemplate template, String ip) {
        this.template = template;
        this.ip = ip;
    }

    @Override
    public void run() {
        // 连接设备
        System.out.format("执行采集数据 %s ...%n", ip);
        //接收设备数据
        List<Report> list = JhscaleCommunicationUtils.getDeviceSales(this.ip);
        //保存本地数据库
        if (list != null && !list.isEmpty())
            storeSalesOrder(list);
    }
}