线程与线程池开发核心技术

发表于 分类于 阅读次数：

线程与线程池开发核心技术

[TOC]

印象笔记链接

线程与进程

  • 一个进程至少一个线程
  • 进程可以包含多个线程
  • 进程在执行过程中拥有独立的内存空间，而线程运行在进程内

线程的几种创建方式

  • new Thread：可复写Thread#run方法。也可传递Runnable对象，
    • 更加灵活。
    • 缺点：缺乏统一管理，可能无限制新建线程，相互之间竞争，及可能占用过多系统资源导致死机或oom
1
2
3
4
5
6
7
8
9
10
11
12
//传递Runnable对象 
1.new Thread(new Runnable(){
    .....
}).start()

//复写Thread#run方法
2.class MyThread extends Thread{ 
        public void run(){ 
                .... 
        }
  }
  new MyThread().start()
  • AysncTask,轻量级的异步任务工具类,提供任务执行的进度回调给UI线程
    • 场景：需要知晓任务执行的进度,多个任务串行执行
    • 缺点：生命周期和宿主的生命周期不同步,有可能发生内存泄漏,默认情况所有任务串行执行
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
   class MyAsyncTask extends AsyncTask {
   private static final String TAG = "MyAsyncTask"; 
   
   @Override 
   protected String doInBackground(String... params) { 
       for (int i = 0; i < 10; i++) {
           publishProgress(i * 10); 
       }
       return params[0];
   } 
   
   @Override 
   protected void onPostExecute(String result) {
           Log.e(TAG, "result: " + result); 
   } 
   
   @Override
   protected void onProgressUpdate(Integer... values) {
           Log.e(TAG, "onProgressUpdate: " + values[0].intValue()); 
   } 
} 
// #1 子类复写方法 
AsyncTask asyncTask = new MyAsyncTask(); 
//AsyncTask所有任务默认串行执行 
asyncTask.execute("execute MyAsyncTask"); 
or 
asyncTask.executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR,"execute MyAsyncTask") // #2 使用#execute方法，同样串行执行 
AsyncTask.execute(new Runnable() {
       @Override public void run() {
           ...... 
        }
 });
 // #3 使用内置THREAD_POOL_EXECUTOR线程池 并发执行 
 AsyncTask.THREAD_POOL_EXECUTOR.execute(new Runnable() { 
           @Override public void run() {
           } 
 });
  • HandlerThread,适用于主线程需要和工作线程通信,适用于持续性任务,比如轮训的场景，所有任务串行执行
  • 缺点:不会像普通线程一样主动销毁资源，会一直运行着，所以可能会造成内存泄漏
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
HandlerThread thread = new HandlerThread("concurrent-thread"); 
thread.start(); 
ThreadHandler handler = new ThreadHandler(thread.getLooper()) { 
    @Override 
    public void handleMessage(@NonNull Message msg) { 
        switch (msg.what) {
            case MSG_WHAT_FLAG_1: 
                break;
            }
         } 
     }; 
handler.sendEmptyMessage(MSG_WHAT_FLAG_1); 
hread.quitSafely();

//定义成静态,防止内存泄漏 
static class ThreadHandler extends Handler{ 
    public ThreadHandler(Looper looper){ 
        super(looper)
    } 
}
  • IntentService,适用于我们的任务需要跨页面读取任务执行的进度，结果。比如后台上传图片，批量操作数据库等。任务执行完成功后，就会自我结束，所以不需要手动stopservice,这是他跟service的区分 
1
2
class MyIntentService extends IntentService{ 
@Override protected void onHandleIntent(@Nullable Intent intent) { int command = intent.getInt("command") ...... } } context.startService(new Intent())
  • ✨ThreadPoolExecutor:适用快速处理大量耗时较短的任务场景 
    1
    2
    3
    4
    Executors.newCachedThreadPool();//线程可复用线程池
    Executors.newFixedThreadPool();//固定线程数量的线程池 
    Executors.newScheduledThreadPool();//可指定定时任务的线程池 
    Executors.newSingleThreadExecutor();//线程数量为1的线程池