spring线程池的理解和使用

迷南。 2022-05-26 09:23 208阅读 0赞

**1、spring线程池**

**2、测试线程池**

*  需要的jar包

![70][]

*  测试代码：

package com.yw.thread.spring;
    
    import java.util.ArrayList;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
    
    public class MyThreadTaskTest {
    	
    	//@Autowired
    	//private ThreadPoolTaskExecutor taskExecutor;
    	
    	public static void main(String[] args) {
    		ApplicationContext ctx = new ClassPathXmlApplicationContext("spring-context.xml");  
    		ThreadPoolTaskExecutor taskExecutor =  (ThreadPoolTaskExecutor)ctx.getBean("taskExecutor");  
    		new MyThreadTaskTest().testTaskExecutor(taskExecutor);
    		new MyThreadTaskTest().testTaskExecutor(taskExecutor);
    	
    	}
    	
    	public void testTaskExecutor(ThreadPoolTaskExecutor taskExecutor) {
    		List<String> list = new ArrayList<String>();
    		list.add("章程");
    		list.add("流苏");
    		list.add("漾须");
    		
    		Map<String, String> map = new HashMap<String, String>();
    		for (int i=0; i<10; i++) {
    			taskExecutor.execute(new testFor(list, map));
    		}
    		//不需要shutdown，否则这个线程池用过一次就不能再用了
    		//taskExecutor.shutdown();
    		//如果想要所有子线程执行完再执行主线程，那么就需要直接用到taskExecutor.getActiveCount()来判断
    		while(true){
    			if(taskExecutor.getActiveCount() == 0){
    				break;
    			}
                        Thread.sleep(200);    
                    }
    		System.out.println("执行完毕===========================");
    		System.out.println(map.toString());
    		
    	}
    }
    
    class testFor implements Runnable{
    	
    	private List<String> list;
    	
    	private Map<String, String> map;
    	
    	public testFor(List<String> list, Map<String, String> map) {
    		this.list = list;
    		this.map = map;
    	}
    
    	@Override
    	public void run() {
    		for (int i = 0; i < list.size(); i++) {
    			System.out.println(Thread.currentThread().getName()+"="+list.get(i));
    			map.put(Thread.currentThread().getName()+ "----" + i, list.get(i));
    		}
    	}
    }

[70]: /images/20220526/744e8c40887c4f1283ca011a400ae81e.png