簡單線程池開啓線程

線程池：

serviceimpl 層進行調用：

ArrayBlockingQueue<Runnable> arrayWorkQueue = new ArrayBlockingQueue(50000);
ExecutorService threadPool = new ThreadPoolExecutor(
        10, //corePoolSize線程池中核心線程數
        50, //maximumPoolSize 線程池中最大線程數
        60, //線程池中線程的最大空閒時間，超過這個時間空閒線程將被回收
        TimeUnit.SECONDS,//時間單位
        arrayWorkQueue,
        new ThreadPoolExecutor.DiscardOldestPolicy()//若是執行程序還沒有關閉，則位於工做隊列頭部的任務將被刪除，而後重試執行程序（若是再次失敗，則重複此過程）
);

 /**
   *這裏也能夠寫一些操做，好比說對數據的加減乘除
   *
   */

 

 //每1000條開啓一條線程
    if (list.size() >= 1000) {
        List<TBalances> list1 = new ArrayList();
        list1.addAll(list);
        threadPool.execute(new BatchThread(list1));
        list = new ArrayList<TBalances>();
    }

}

if (list.size() > 0) {
    threadPool.execute(new BatchThread(list));
}

util 類：
開啓的線程類（實際線程操做）：

import cn.hc.erp.base.model.TBalances;
import cn.hc.erp.base.service.DetailService;

import java.util.List;

public class BatchThread implements Runnable {

    private DetailService detailService = SpringUtil.getBean("detailService", DetailService.class);

    private List<TBalances> list;

    public BatchThread(List<TBalances> list) {
        this.list = list;
    }

    public BatchThread() {

    }


    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + "正在執行");
        detailService.updateBatch(this.list);
        detailService.batchInsert(this.list);
        //爲了減緩數據庫壓力，人工干預延遲5秒釋放線程資源
        try {
            Thread.currentThread().sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

    }

}

獲取detailService的SpringUtil類：

import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.stereotype.Service;

@Service("springContextUtil")
public class SpringUtil implements ApplicationContextAware {
    private static ApplicationContext applicationContext;
   @Override
   public void setApplicationContext(ApplicationContext arg0)
         throws BeansException {
      SpringUtil.applicationContext = arg0;

   }
   public static Object getBean(String name){
        return applicationContext.getBean(name);
    }
   
   public static <T> T getBean(String name,Class<T> clazz){
        return applicationContext.getBean(name,clazz);
    }
   
   
   public static <T> T getBean(Class<T> clazz){
        return applicationContext.getBean(clazz);
    }
}

爲了避免讓子線程隨着主線程結束：

Scanner scanner = new Scanner(System.in);System.out.println("********" + scanner.nextLine());