package com.javaweb.common.utils.thread.exception;



import com.javaweb.common.utils.thread.exception.util.ExceptionMessageFormat;
import com.javaweb.common.utils.thread.exception.util.factory.ExceptionMsgFormatFactory;

import java.io.PrintStream;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;


/**
 * 子线程异常，子线程出现异常时抛出
 * @author zengyuanjun
 */
public class ChildThreadException extends Exception {

	/**
	 * serialVersionUID
	 */
	private static final long serialVersionUID = 5682825039992529875L;
	/**
	 * 子线程的异常列表
	 */
	private List<Exception> exceptionList;
	/**
	 * 异常信息格式化工具
	 */
	private ExceptionMessageFormat formatter;
	/**
	 * 锁
	 */
	private Lock lock;

	public ChildThreadException() {
		super();
		initial();
	}

	public ChildThreadException(String message) {
		super(message);
		initial();
	}

	public ChildThreadException(String message, StackTraceElement[] stackTrace) {
		this(message);
		setStackTrace(stackTrace);
	}

	private void initial() {
		exceptionList = new ArrayList<Exception>();
		lock = new ReentrantLock();
		formatter = ExceptionMsgFormatFactory.getInstance().getFormatter(ExceptionMsgFormatFactory.STACK_TRACE);
	}

	/**
	 * 子线程是否有异常
	 * @return
	 */
	public boolean hasException() {
		return exceptionList.size() > 0;
	}

	/**
	 * 添加子线程的异常
	 * @param e
	 */
	public void addException(Exception e) {
		try {
			lock.lock();
			e.setStackTrace(e.getStackTrace());
			exceptionList.add(e);
		} finally {
			lock.unlock();
		}
	}

	/**
	 * 获取子线程的异常列表
	 * @return
	 */
	public List<Exception> getExceptionList() {
		return exceptionList;
	}

	/**
	 * 清空子线程的异常列表
	 */
	public void clearExceptionList() {
		exceptionList.clear();
	}

	/**
	 * 获取所有子线程异常的堆栈跟踪信息
	 * @return
	 */
	public String getAllStackTraceMessage() {
		StringBuffer sb = new StringBuffer();
		for (Exception e : exceptionList) {
			sb.append(e.getClass().getName());
			sb.append(": ");
			sb.append(e.getMessage());
			sb.append("\n");
			sb.append(formatter.formate(e));
		}
		return sb.toString();
	}

	/**
	 * 打印所有子线程的异常的堆栈跟踪信息
	 */
	public void printAllStackTrace() {
		printAllStackTrace(System.err);
	}

	/**
	 * 打印所有子线程的异常的堆栈跟踪信息
	 * @param s
	 */
	public void printAllStackTrace(PrintStream s) {
		for (Exception e : exceptionList) {
			e.printStackTrace(s);
		}
	}

}