设计线程监控代码结构

Myth丶恋晨 2022-08-09 14:55 185阅读 0赞

线程监控:

/**
     * 线程状态的监控
     * @author dell
     *
     */
    public class Test5 extends RunnableWrapper {
    
    	@Override
    	public void handler() {
    		System.out.println("xxxxxx");
    	}
    
    	public static void main(String[] args) {
    		Thread t = new Thread(new Test5());
    		t.start();
    	}
    }
    
    interface ThreadListner {
    	
    	public Object threadStart(Object[] args);
    	
    	public Object threadRunning(Object[] args);
    	
    	public Object threadFinish(Object[] args);
    	
    	public Object threadException(Object[] args);
    	
    }
    
    
    
    abstract class RunnableWrapper implements Runnable {
    	
    	private ThreadListner threadListener = null;
    	
    	private static ThreadListner DEFAULT_THREADLISTENER = new ThreadListner() {
    		
    		private String name = Thread.currentThread().getName();
    		
    		@Override
    		public Object threadStart(Object[] args) {
    			System.out.println(name + " start...");
    			return null;
    		}
    		
    		@Override
    		public Object threadRunning(Object[] args) {
    			System.out.println(name + " running...");
    			return null;
    		}
    		
    		@Override
    		public Object threadFinish(Object[] args) {
    			System.out.println(name + " finish...");
    			return null;
    		}
    		
    		@Override
    		public Object threadException(Object[] args) {
    			System.out.println(name + " exception...");
    			return null;
    		}
    	};
    
    	public RunnableWrapper(ThreadListner threadListener) {
    		this.threadListener = threadListener;
    	}
    
    	public RunnableWrapper() {
    		this(DEFAULT_THREADLISTENER);
    	}
    
    	
    	@Override
    	public void run() {
    		try {
    			threadListener.threadStart(null);
    			handler();
    			threadListener.threadFinish(null);
    		} catch (Exception e) {
    			threadListener.threadException(null);
    		}
    		
    	}
    	
    	abstract public void handler();
    }