在java项目中使用线程池实现并发编程

public class MyAppThread extends Thread {  public static final String DEFAULT_NAME = "MyAppThread";  private static volatile boolean debugLifecycle = false;  private static final AtomicInteger created = new AtomicInteger();  private static final AtomicInteger alive = new AtomicInteger();  private static final Logger log = Logger.getAnonymousLogger();  public MyAppThread(Runnable r) {    this(r, DEFAULT_NAME);  }  public MyAppThread(Runnable runnable, String name) {    super(runnable, name + "-" + created.incrementAndGet());    //设置该线程工厂创建的线程的 未捕获异常的行为    setUncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() {      public void uncaughtException(Thread t,                     Throwable e) {        log.log(Level.SEVERE,            "UNCAUGHT in thread " + t.getName(), e);      }    });  }  public void run() {    // Copy debug flag to ensure consistent value throughout.    boolean debug = debugLifecycle;    if (debug) log.log(Level.FINE, "Created " + getName());    try {      alive.incrementAndGet();      super.run();    } finally {      alive.decrementAndGet();      if (debug) log.log(Level.FINE, "Exiting " + getName());    }  }  public static int getThreadsCreated() {    return created.get();  }  public static int getThreadsAlive() {    return alive.get();  }  public static boolean getDebug() {    return debugLifecycle;  }  public static void setDebug(boolean b) {    debugLifecycle = b;  }}