The use of thread pool two

• 业务场景:
• 导入文件,To process a bunch of data in the file,For user experience, it can only be imported and returned immediately上传成功,In fact, the import status is directly recorded first(处理中),Then the thread pool finishes processing and changes the state to处理完成
• 1. 上传文件,Store the file in yourselfdfs文件系统,拿到地址url链接,然后生成一个任务idRecord and this address in the database tableurl, create a new taskid放入本地缓存ConcurrentLinkedQueue中
• 2. Throw thread tasks into the thread pool to process business asynchronously, Process thread tasks asynchronously,Tasks are cached locallyConcurrentLinkedQueuetask to get table dataidto obtain the fileurl地址,Get the data of the file,Then traverse the file data for business processing,After processing, update the database status to 处理成功或处理失败

线程池

• 定义线程池,调用方法executeThrow in thread tasks

public class BossThreadFactory {
    

	public static ThreadPoolExecutor threadPoolExecutor;


	static {
    
		int corePoolSize = 2;
		threadPoolExecutor = new ThreadPoolExecutor(corePoolSize, 2, 1, TimeUnit.SECONDS,
				new LinkedBlockingQueue<>(20), new ThreadFactoryBuilder().setNameFormat("boss-%d").build(),
				new ThreadPoolExecutor.AbortPolicy());
	}

	public static void execute(Runnable runnable){
    
			threadPoolExecutor.execute(runnable);
	}



}

线程任务

@Component
public class NumberStateThread extends Thread {
    

    private static final Logger logger = LoggerFactory.getLogger(NumberStateThread.class);

    // The task that holds the imported fileid
    public static ConcurrentLinkedQueue<Integer> threadLinkedQueue = new ConcurrentLinkedQueue<>();



    @Override
    public void run() {
    
   // Get data from the local cache queue
        Integer taskId = threadLinkedQueue.poll();
        //处理后续业务
    }
}
 

实战(参考即可)

• Put thread tasks into the thread pool

 	@Autowired
    private NumberStateThread numberStateThread;


 	@Override
    public Result uploadFile(MultipartFile file) throws Exception {
    
		//Put data into the local cache queue
 	 boolean offerB = NumberStateThread.threadLinkedQueue.offer(mobileTypeState.getId());
        if (offerB) {
    
            logger.info("【checkStateNumberUpload】将任务ID[{}]Put into the local cache queue successfully", mobileTypeState.getId());
            //Put the thread task into the thread pool for execution
            BossThreadFactory.execute(numberStateThread);
			}
}