/** * @描述    線(xiàn)程管理池 * @項(xiàng)目名稱(chēng)   App_Shop * @包名     com.android.shop.manager * @類(lèi)名     ThreadManager * @author   chenlin * @date    2014年3月29日 下午10:17:06 */public class ThreadManager {  private ThreadManager(){};  private static ThreadManager instance= new ThreadManager();  private ThreadPoolProxy longPoolProxy;  private ThreadPoolProxy shortPoolProxy;  public static ThreadManager getInstance(){    return instance;  }  /**   * 長(zhǎng)線(xiàn)程池   * @return   */  public synchronized ThreadPoolProxy createLongPool(){    if (longPoolProxy == null) {      //(int corePoolSize 線(xiàn)程池大小, int maximumPoolSize 最大值, long keepAliveTime 存活時(shí)間)      longPoolProxy = new ThreadPoolProxy(5, 5, 5000);    }    return longPoolProxy;  }  /**   * 短線(xiàn)程池   * @return   */  public synchronized ThreadPoolProxy createShortPool(){    if (shortPoolProxy == null) {      shortPoolProxy = new ThreadPoolProxy(3, 3, 5000);    }    return shortPoolProxy;  }  public class ThreadPoolProxy{    private ThreadPoolExecutor pool;    private int corePoolSize; //線(xiàn)程數(shù)    private int maximumPoolSize; //線(xiàn)程滿(mǎn)了后額外開(kāi)的線(xiàn)程窗口    private long keepAliveTime;//沒(méi)有線(xiàn)程執(zhí)行時(shí)存活時(shí)間    public ThreadPoolProxy(int corePoolSize,int maximumPoolSize, long keepAliveTime){      this.corePoolSize = corePoolSize;      this.maximumPoolSize = maximumPoolSize;      this.keepAliveTime = keepAliveTime;    }    /**     * 執(zhí)行線(xiàn)程     * @param runnable     */    public void execute(Runnable runnable){      if (pool == null) {        //最多可有多少個(gè)線(xiàn)程排隊(duì)        BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<Runnable>(10);        pool = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, TimeUnit.MILLISECONDS, workQueue);      }      pool.execute(runnable);    }    /**     * 取消線(xiàn)程     * @param runnable     */    public void cancel(Runnable runnable){      if (pool != null) {        pool.remove(runnable);      }    }  }}

ThreadManager.getInstance().createLongPool().execute(new Runnable() {  @Override  public void run() {    //SystemClock.sleep(2000);    final LoadResult result = loadFromServer();    if (result != null) {      Util.runOnUiThread(new Runnable() {        @Override        public void run() {          currentState = result.getValue();          showPages();        }      });    }  }});