Spring-Boot中如何使用多執行緒處理任務 
看到這個標題，相信不少人會感到疑惑，回憶你們自己的場景會發現，在Spring的專案中很少有使用多執行緒處理任務的，沒錯，大多數時候我們都是使用Spring MVC開發的web專案，預設的Controller，Service，Dao元件的作用域都是單例項，無狀態，然後被併發多執行緒呼叫，那麼如果我想使用多執行緒處理任務，該如何做呢？ 

比如如下場景： 

使用spring-boot開發一個監控的專案，每個被監控的業務（可能是一個數據庫表或者是一個pid程序）都會單獨執行在一個執行緒中，有自己配置的引數，總結起來就是： 

（1）多例項（多個業務，每個業務相互隔離互不影響） 

（2）有狀態（每個業務，都有自己的配置引數） 

如果是非spring-boot專案，實現起來可能會相對簡單點，直接new多執行緒啟動，然後傳入不同的引數類即可，在spring的專案中，由於Bean物件是spring容器管理的，你直接new出來的物件是沒法使用的，就算你能new成功，但是bean裡面依賴的其他元件比如Dao，是沒法初始化的，因為你饒過了spring，預設的spring初始化一個類時，其相關依賴的元件都會被初始化，但是自己new出來的類，是不具備這種功能的，所以我們需要通過spring來獲取我們自己的執行緒類，那麼如何通過spring獲取類例項呢，需要定義如下的一個類來獲取SpringContext上下文： 

/** 
* Created by Administrator on 2016/8/18. 
* 設定Sping的上下文 
*/ 
@Component 
public class ApplicationContextProvider implements ApplicationContextAware { 

    private static ApplicationContext context; 

    private ApplicationContextProvider(){} 

    @Override 
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException { 
        context = applicationContext; 
    } 

    public  static <T> T getBean(String name,Class<T> aClass){ 
        return context.getBean(name,aClass); 
    } 


} 
然後定義我們的自己的執行緒類，注意此類是原型作用域，不能是預設的單例： 

@Component("mTask") 
@Scope("prototype") 
public class MoniotrTask extends Thread { 

    final static Logger logger= LoggerFactory.getLogger(MoniotrTask.class); 
    //引數封裝 
    private Monitor monitor; 
    
    public void setMonitor(Monitor monitor) { 
        this.monitor = monitor; 
    } 

    @Resource(name = "greaterDaoImpl") 
    private RuleDao greaterDaoImpl; 

    @Override 
    public void run() { 
        logger.info("執行緒:"+Thread.currentThread().getName()+"執行中....."); 
    } 

} 
寫個測試例子，測試下使用SpringContext獲取Bean，檢視是否是多例項： 

/** 
* Created by Administrator on 2016/8/18. 
*/ 
@RunWith(SpringJUnit4ClassRunner.class) 
@SpringBootTest(classes =ApplicationMain.class) 
public class SpingContextTest { 



    @Test 
    public void show()throws Exception{ 
        MoniotrTask m1=   ApplicationContextProvider.getBean("mTask", MoniotrTask.class); 
        MoniotrTask m2=ApplicationContextProvider.getBean("mTask", MoniotrTask.class); 
        MoniotrTask m3=ApplicationContextProvider.getBean("mTask", MoniotrTask.class); 
        System.out.println(m1+" => "+m1.greaterDaoImpl); 
        System.out.println(m2+" => "+m2.greaterDaoImpl); 
        System.out.println(m3+" => "+m3.greaterDaoImpl); 

    } 


} 
執行結果如下： 

[ INFO ] [2016-08-25 17:36:34] com.test.tools.SpingContextTest [57] - Started SpingContextTest in 2.902 seconds (JVM running for 4.196) 
2016-08-25 17:36:34.842  INFO 8312 --- [           main] com.test.tools.SpingContextTest          : Started SpingContextTest in 2.902 seconds (JVM running for 4.196) 
Thread[Thread-2,5,main] =>

[email protected] 
Thread[Thread-3,5,main] => [email protected] 
Thread[Thread-4,5,main] => [email protected] 
可以看到我們的監控類是多例項的，它裡面的Dao是單例項的，這樣以來我們就可以在spring中使用多執行緒處理我們的任務了。 

如何啟動我們的多執行緒任務類，可以專門定義一個元件類啟動也可以在啟動Spring的main方法中啟動，下面看下，如何定義元件啟動： 

@Component 
public class StartTask   { 

    final static Logger logger= LoggerFactory.getLogger(StartTask.class); 
    
    //定義在構造方法完畢後，執行這個初始化方法 
    @PostConstruct 
    public  void init(){ 

        final List<Monitor> list = ParseRuleUtils.parseRules(); 
        logger.info("監控任務的總Task數：{}",list.size()); 
        for(int i=0;i<list.size();i++) { 
            MoniotrTask moniotrTask=   ApplicationContextProvider.getBean("mTask", MoniotrTask.class); 
            moniotrTask.setMonitor(list.get(i)); 
            moniotrTask.start(); 
            logger.info("第{}個監控task: {}啟動 !",(i+1),list.get(i).getName()); 
        } 

    } 


}

參考資料

https://www.cnblogs.com/qindongliang/p/5808145.html