Java使用ThreadFactory来创建新的线程

落日映苍穹つ 2021-11-22 10:02 470阅读 0赞

首先来构建线程封装类WorkThread,该类的功能主要是为了能够更好的管理线程而创建的

public class WorkThread extends Thread {	 
    	    private Runnable target;   //线程执行目标
    	    private AtomicInteger counter;  
    	 
    	    public WorkThread(Runnable target, AtomicInteger counter) {  
    	        this.target = target;  
    	        this.counter = counter;  
    	    }  
    	    @Override 
    	    public void run() {  
    	        try {  
    	            target.run();  
    	        } finally {  
    	            int c = counter.getAndDecrement();  
    	            System.out.println("terminate no " + c + " Threads");  
    	        }  
    	    }  
    }

其次，来定义一个测试目标

public class WorkRunnable implements Runnable
    {
    	@Override
    	public void run() {
    		 System.out.println("complete a task");
    	}
    
    }

实现线程工厂的方法

public class WorkThreadFactory implements ThreadFactory{
    	
    	private AtomicInteger atomicInteger = new AtomicInteger(0);
    	
    	@Override
    	public Thread newThread(Runnable r)
    	{
    		int c = atomicInteger.incrementAndGet();  
                    System.out.println("create no " + c + " Threads");  
    		return new WorkThread(r, atomicInteger);//通过计数器，可以更好的管理线程
    	}
    
    }

测试线程工厂

public class TestThreadFactory {
    
    	public static void main(String[] args) {
    		//创建线程（并发）池，自动伸缩(自动条件线程池大小)
    		ExecutorService es =  Executors.newCachedThreadPool(new WorkThreadFactory());
    
    		//同时并发5个工作线程
    		es.execute(new WorkRunnable());
    		es.execute(new WorkRunnable());
    		es.execute(new WorkRunnable());
    		es.execute(new WorkRunnable());
    		es.execute(new WorkRunnable());
    		//指示当所有线程执行完毕后关闭线程池和工作线程，如果不调用此方法，jvm不会自动关闭
    	       es.shutdown();  
    	    
    	    try {  
    	         //等待线程执行完毕，不能超过2*60秒，配合shutDown
    	          es.awaitTermination(2*60, TimeUnit.SECONDS);  
    	     } catch (InterruptedException e) {  
    	            e.printStackTrace();  
    	     }  
    	}
    	
    }

最后给你们推荐一个群，如果你还想提升自己

欢迎加入Java技术交流群：659270626

群内提供免费的学习指导,提供Spring源码、MyBatis、Netty、Redis,Kafka、Mysql、Zookeeper、Tomcat、Docker、Dubbo、Nginx、分布式、高并发、性能调优等架构技术架构资料以及免费的解答

不懂的问题都可以在本群提出来,之后还会有职业生涯规划以及面试指导