線程池的簡單使用

創建指定線程數量的線程池

private static ExecutorService scheduledTaskFactoryExecutor = null;

private boolean isCancled = false;

private static class ThreadFactoryTest implements ThreadFactory {

@Override
public Thread newThread(Runnable r) {
         Thread thread = new Thread(r);
　　　　　thread.setName(TAG);
　　　　　 //通過Thread.setDaemon(false)設置為用戶線程；通過Thread.setDaemon(true)設置為守護線程
         //主線程結束后用戶線程還會繼續運行,JVM存活；主線程結束后守護線程和JVM的狀態又下面第2條確定
         //如果沒有用戶線程，都是守護線程，那么JVM結束（隨之而來的是所有的一切煙消云散，包括所有的守護線程）
         //安卓程序退出后jvm會被回收掉，而java程序基于服務的退出后jvm不會立馬回收
　　　　　thread.setDaemon(true);
        　　return thread;
　　　　　}
}

static {
scheduledTaskFactoryExecutor = Executors.newFixedThreadPool(3, new ThreadFactoryTest());
　　 scheduledTaskFactoryExecutor.submit(new Runnable() {
@Override
　　　　public void run() {
            Log.i(TAG, "This is the ThreadFactory Test  submit Run! ! ! ");
　　　　}
    });
}

AsyncTaskTest task = new AsyncTaskTest(url);

//把定義好的線程在線程池執行

task.executeOnExecutor(scheduledTaskFactoryExecutor);
mTaskList.add(task);

class AsyncTaskTest extends AsyncTask<Void, Integer, Void> {//異步任務

private String url;

    public AsyncTaskTest(String url) {
this.url = url;
    }

@Override
    protected Void doInBackground(Void... params) {
if (!isCancelled() && isCancled == false) // 這個地方很關鍵，如果不設置標志位的話，直接setCancel（true）是無效的
　　　　　{
            Bitmap bmp;
            if (!url.contains("http")) {//表示網絡圖片
　　　　　　　　bmp = ImageLoader.getInstance().loadImageSync("file://" + url, options);
　　　　  } else {
                bmp = ImageLoader.getInstance().loadImageSync(url, options);
　　　　  }
　　     if (bmp != null) {
byte[] b = new byte[0];
              try {
                    b = MyImageUtil.getImageThumbnailBase(bmp);
　　　　　　　　　　　　upload(b);
　　　　　　　　　　　　publishProgress(count); // 更新進度條
　　　　　　　　} catch (IOException e) {
                    UMDocApplication.getInstance().getLog().e(e);
　　　　　　　　}
                Log.d(TAG, "byte length " + b.length);
　　　　　　　　}
        }
return null;
    }

@Override
    protected void onProgressUpdate(Integer... values) {
        Log.d(TAG, "count " + values[0]);
        if (values[0] == 1)
proBar.setVal(count);
    }

}