分类导航

程序笔记发布时间：2022-06-07 发布网站：大佬教程 code.js-code.com

大佬教程收集整理的这篇文章主要介绍了浅谈Android中线程池的管理，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。

说到线程就要说说线程机制 Handler,Looper,messageQueue 可以说是三座大山了

Handler

Handler 其实就是一个处理者，或者说一个发送者，它会把消息发送给消息队列，也就是Looper，然后在一个无限循环队列中进行取出消息的操作 mMyHandler.sendmessage(mmessagE); 这句话就是我耗时操作处理完了，我发送过去了! 然后在接受的地方处理！简单理解是不是很简单。

一般我们在项目中异步操作都是怎么做的呢？

// 这里开启一个子线程进行耗时操作
 new Thread() {
  @OverrIDe
  public voID run() {
   .......
   message mmessage = new message();
   mmessage.what = 1;
   //在这里发送给消息队列
   mMyHandler.sendmessage(mmessagE);
   }
  }.start();
 /**
  * 这里就是处理的地方 通过msg.what进行处理分辨
  */
 class MyHandler extends Handler{
  @OverrIDe
  public voID handlemessage(message msg) {
   super.handlemessage(msg);
   switch (msg.what){
   //取出对应的消息进行处理
    ........
   }
  }
 }

那么我们的消息队列是在什么地方启动的呢?跟随源码看一看

# ActivityThread.main
public static voID main(String[] args) {
  //省略代码。。。。。
  
  //在这里创建了一个消息队列！
  Looper.prepareMainLooper();

  ActivityThread thread = new ActivityThread();
  thread.attach(false);

  if (smainThreadHandler == null) {
   smainThreadHandler = thread.getHandler();
  }

  //这句我也没有看懂 这不是一直都不会执行的么
  if (false) {
   Looper.myLooper().setmessageLogging(new
     LogPrinter(Log.DEBUG,"ActivityThread"));
  }

  Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
  //消息队列跑起来了！
  Looper.loop();

  throw new RuntimeException("Main thread loop unexpectedly exited");
 }

public Handler(CallBACk callBACk,Boolean asynC) {
  mLooper = Looper.myLooper();
  //注意看这里抛出的异常 如果这里mLooper==null
  if (mLooper == null) {
   throw new RuntimeException(
    "Can't create handler insIDe thread that has not called Looper.prepare()");
  }
  //获取消息队列
  mQueue = mLooper.mQueue;
  mCallBACk = callBACk;
  mAsynchronous = async;
 }

以上操作AndroID系统就获取并且启动了一个消息队列，过多的源码这里不想去描述，免的占用很多篇幅

这里说一下面试常见的一个问题，就是在子线程中可不可以创建一个Handler，其实是可以的，但是谁这么用啊- -

new Thread() {
  Handler mHandler = null;
  @OverrIDe
  public voID run() {
   //在这里获取
   Looper.prepare();
   mHandler = new Handler();
   //在这里启动
   Looper.loop();
  }
 }.start();

多线程的创建

一般我们在开发过程中要开启一个线程都是直接

new Thread() {
   @OverrIDe
   public voID run() {
    doing.....
   }
  }.start();

new Thread(new Runnable() {
   @OverrIDe
   public voID run() {
    doing.....
   }
  }).start();

注意看，一个传递了Runnable对象，另一个没有,但是这两个有什么不同，为什么要衍生出2个呢？

这里不去看源码，简单叙述一下，实际上Thread是 Runnabled的一个包装实现类，Runnable只有一个方法，就是run(),在这里以前也想过，为什么Runnable只有一个方法呢，后来的某一次交谈中也算是找到一个答案，可能是因为多拓展，可能JAVA语言想拓展一些其他的东西，以后就直接在Runnable再写了。不然我是没有想到另一答案为什么都要传递一个Runnable,可能就像我们开发中的baseActivity一样吧

线程常用的操作方法

wait() 当一个线程执行到了wait() 就会进去一个和对象有关的等待池中，同时失去了释放当前对象的机所，使其他线程可以访问，也就是让其他线程可以调用notify()唤醒
sleep() 调用得线程进入睡眠状态，不能该改变对象的机锁，其他线程不能访问
join() 就等自己完事
yIDld 你急你先来

简单的白话叙述其实也就是这样，希望能看看demo然后理解一下。

一些其他的方法，Callable,Future,FutureTask

Runnable是线程管理的拓展接口，不可以运用于线程池,所以你总要有方法可以在线程池中管理啊所以Callable,FutureTask就是可以在线程池中开启线程的接口。

Future定义了规范的接口，如get(),isDone(),isCancelled()... FutureTask 是他的实现类这里简单说一下他的用法

/**
 * ================================================
 * 作 者：夏沐尧 Github地址：https://github.com/XiaMuYaoDQX
 * 版 本：1.0
 * 创建日期： 2018/1/10
 * 描 述：
 * 修订历史：
 * ================================================
 */
class FutureDemo {
 //创建一个单例线程
 static Executorservice mExecutor = Executors.newSingleThreadscheduledExecutor();

 public static voID main(String[] args) throws ExecutionException,InterruptedException {
  ftureWithRunnable();
  ftureWithCallable();
  ftureTask();
 }

 /**
  * 没有指定返回值，所以返回的是null,向线程池中提交的是Runnable
  *
  * @throws ExecutionException
  * @throws InterruptedException
  */
 private static voID ftureWithRunnable() throws ExecutionException,InterruptedException {
  Future<?> result1 = mExecutor.submit(new Runnable() {
   @OverrIDe
   public voID run() {
    fibc(20);
    System.out.println(Thread.currentThread().getname());
   }
  });
  System.out.println("Runnable" + result1.get());
 }

 /**
  * 提交了Callable，有返回值，可以获取阻塞线程获取到数值
  *
  * @throws ExecutionException
  * @throws InterruptedException
  */
 private static voID ftureWithCallable() throws ExecutionException,InterruptedException {
  Future<Integer> result2 = mExecutor.submit(new Callable<Integer>() {
   @OverrIDe
   public Integer call() throws Exception {
    System.out.println(Thread.currentThread().getname());
    return fibc(20);
   }
  });
  System.out.println("Callable" + result2.get());
 }

 /**
  * 提交的futureTask对象
  * @throws ExecutionException
  * @throws InterruptedException
  */
 private static voID ftureTask() throws ExecutionException,InterruptedException {
  FutureTask<Integer> futureTask = new FutureTask<Integer>(new Callable<Integer>() {
   @OverrIDe
   public Integer call() throws Exception {
    System.out.println(Thread.currentThread().getname());
    return fibc(20);
   }
  });
  mExecutor.submit(futureTask);
  System.out.println("futureTask" + futureTask.get());

 }

 private static int fibc(int num) {
  if (num == 0) {
   return 0;
  }
  if (num == 1) {
   return 1;
  }
  return fibc(num - 1) + fibc(num - 2);
 }
}

线程池

Java通过Executors提供线程池，分别为：

newCachedThreadPool创建一个可缓存线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收，则新建线程。
newFixedThreadPool 创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。
newscheduledThreadPool 创建一个定长线程池，支持定时及周期性任务执行。
newSingleThreadExecutor 创建一个单线程化的线程池，它只会用唯一的工作线程来执行任务，保证所有任务按照指定顺序(FIFO,liFO,优先级)执行。

示例代码

newCachedThreadPool

创建一个可缓存线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收，则新建线程。示例代码如下：

public class ThreadPoolExecutorTest { 
 public static voID main(String[] args) { 
 Executorservice cachedThreadPool = Executors.newCachedThreadPool(); 
 for (int i = 0; i < 10; i++) { 
 final int index = i; 
 try { 
 Thread.sleep(index * 1000); 
 } catch (InterruptedException E) { 
 e.printstacktrace(); 
 } 
 cachedThreadPool.execute(new Runnable() { 
 public voID run() { 
  System.out.println(indeX); 
 } 
 }); 
 } 
 } 
}

线程池为无限大，当执行第二个任务时第一个任务已经完成，会复用执行第一个任务的线程，而不用每次新建线程。

newFixedThreadPool

创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。示例代码如下：

public class ThreadPoolExecutorTest { 
 public static voID main(String[] args) { 
 Executorservice fixedThreadPool = Executors.newFixedThreadPool(3); 
 for (int i = 0; i < 10; i++) { 
 final int index = i; 
 fixedThreadPool.execute(new Runnable() { 
 public voID run() { 
  try { 
  System.out.println(indeX); 
  Thread.sleep(2000); 
  } catch (InterruptedException E) { 
  e.printstacktrace(); 
  } 
 } 
 }); 
 } 
 } 
}

因为线程池大小为3，每个任务输出index后sleep 2秒，所以每两秒打印3个数字。

定长线程池的大小最好根据系统资源进行设置。如runtime.getRuntime().availableProcessors()

newscheduledThreadPool

创建一个定长线程池，支持定时及周期性任务执行。延迟执行示例代码如下：

public class ThreadPoolExecutorTest { 
 public static voID main(String[] args) { 
 scheduledexecutorservice scheduledThreadPool = Executors.newscheduledThreadPool(5); 
 scheduledThreadPool.schedule(new Runnable() { 
 public voID run() { 
 System.out.println("delay 3 seconds"); 
 } 
 },3,TimeUnit.SECONDS); 
 } 
}

表示延迟3秒执行。

定期执行示例代码如下：

public class ThreadPoolExecutorTest { 
 public static voID main(String[] args) { 
 scheduledexecutorservice scheduledThreadPool = Executors.newscheduledThreadPool(5); 
 scheduledThreadPool.scheduleAtFixedrate(new Runnable() { 
 public voID run() { 
 System.out.println("delay 1 seconds,and excute every 3 seconds"); 
 } 
 },1,TimeUnit.SECONDS); 
 } 
}

表示延迟1秒后每3秒执行一次。

newSingleThreadExecutor

public class ThreadPoolExecutorTest { 
 public static voID main(String[] args) { 
 Executorservice singleThreadExecutor = Executors.newSingleThreadExecutor(); 
 for (int i = 0; i < 10; i++) { 
 final int index = i; 
 singleThreadExecutor.execute(new Runnable() { 
 public voID run() { 
  try { 
  System.out.println(indeX); 
  Thread.sleep(2000); 
  } catch (InterruptedException E) { 
  e.printstacktrace(); 
  } 
 } 
 }); 
 } 
 } 
}

这里只是简单叙述了一下线程的管理的各种方法,后续还会针对锁进行讲解

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持编程小技巧。

您可能感兴趣的文章:

在Android线程池里运行代码任务实例
Android自带的四种线程池使用总结
浅谈Android 的线程和线程池的使用
Android编程自定义线程池与用法示例

大佬总结

以上是大佬教程为你收集整理的浅谈Android中线程池的管理全部内容，希望文章能够帮你解决浅谈Android中线程池的管理所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。

标签：MessageQueue可以说是三座大山了 Handler Handler其实就是一个处理者也就是Looper 它会把消息发送给消息队列或者说一个发送者然后在一个无限循环队列中进行取出消息的说到线程就要说说线程机制Handler

上一篇: Android编程自定义View时添加自己... 下一篇:spring-boot整合ehcache实现缓存...

猜你在找的程序笔记相关文章

You can't specify target table 'xxx' for update in FROM clause的解决 2022-07-21
【UNIAPP】上传视频，进度条的前台与后端 2022-07-21
十款代码表白特效，一个比一个浪漫！ 2022-07-04
作业3 2022-07-06
linux系统下部署项目访问报404错误的解决方法 2022-05-30
C++带有指针成员的类处理方式详解 2022-06-07
Linux——（1）基本命令 2022-07-21
JavaScript之正则表达式学习笔记 2019-11-07
Redux源码学习笔记 2019-11-07
Webpack学习笔记 2019-11-07