spring配置线程池，异步处理

1.首先在spring配置文件中配置线程池

    <bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">

        <property name="corePoolSize" value="5" />

        <property name="maxPoolSize" value="10" />

        <property name="queueCapacity" value="25" />

    </bean>

<bean name="dataSyncService" class="com.aaa.impl.DataSyncServiceImpl">

        <property name="taskExecutor" ref="taskExecutor"/>

    </bean>

 

2.定义使用线程池的实现类

public class DataSyncServiceImpl implements DataSyncService{

 

    private class DataReplacer implements Runnable{

private SomeObject obj;

        

        public DataReplacer(SomeObject obj){

            this.loginResult = loginResult;

        }

        

        @Override

        public void run(){

//TODO

        }

    }

       

    @Override

    public void syncData(SomeObject obj){

        taskExecutor.execute(new DataReplacer(obj));

    }

}