IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 移动开发 -> 实现一个简单的线程池,简单测试可跑通 -> 正文阅读

[移动开发]实现一个简单的线程池,简单测试可跑通

主要是按照ThreadPoolExecutor的执行流程实现的。
实现功能,

  1. 线程池中线程数 小于 corePoolSize 则直接创建一个线程执行任务。
  2. 大于则阻塞到阻塞队列。
  3. 阻塞队列满了 则创建非核心线程执行任务,此时会先执行阻塞队列放不下的那个任务,之后就是超时获取阻塞队列中的任务。
  4. 非核心线程的超时自动销毁。
package ThreeYue;

import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicInteger;

public class Study38 implements Executor {
    //线程池中正在运行的线程数
    private final AtomicInteger ctl = new AtomicInteger();
    //核心线程数
    private volatile int corePoolSize;
    //最大线程数
    private volatile int maximumPoolSize;
    //阻塞队列
    private BlockingQueue<Runnable> workQueue;
    //最大空闲等待时间
    private volatile long keepAliveTime;

    public Study38(int corePoolSize, int maximumPoolSize, BlockingQueue<Runnable> workQueue, long keepAliveTime) {
        this.corePoolSize = corePoolSize;
        this.maximumPoolSize = maximumPoolSize;
        this.workQueue = workQueue;
        this.keepAliveTime = keepAliveTime;
    }

    @Override
    public  void execute(Runnable command) {
        int c = ctl.get();
        //线程数小于核心线程数
        if(c < corePoolSize) {
            //创建线程,并执行任务失败
            if(!addWorker(command)) {
                reject();
            }
            return;
        }

        //加入阻塞队列
        if(workQueue.offer(command)) {
            System.out.println("此时阻塞队列中任务数量 " + workQueue.size());
            System.out.println("加入阻塞队列成功");
            if (c == 0) {//如果此时无存活线程,则直接创建一个线程
                addWorker(null);
            }
        } else {
            System.out.println("加入阻塞队列失败");
            //队列满了,再启动线程,并且携带任务
            if(!addWorker(command)) {
                reject();
            }
        }
    }

    private  boolean addWorker(Runnable command) {

        if (ctl.get() > maximumPoolSize){
            return false;
        }
        if (command == null) {
            System.out.println("非核心线程创建");
        }
        Worker worker = new Worker(command);
        worker.thread.start();
        System.out.println(worker.thread+" 启动了");
        ctl.incrementAndGet();
        return true;
    }
    //饱和拒绝策略
    private void reject() {
        System.out.println("执行拒绝策略");
//        throw new RejectedExecutionException("Task is not excute");
    }

    private final class Worker implements Runnable {

        Runnable firstTask;
        final Thread thread;

        private Worker(Runnable task) {
            this.thread = new Thread(this);
            this.firstTask = task;
        }

        @Override
        public void run() {
            Runnable task = firstTask;
            try{
                //线程活着,一直在这里运行。
                //非核心线程获取不到任务就退出。
                while(task != null || (task = getTask()) != null) {
                    System.out.println(Thread.currentThread()+"获取了任务");
                    task.run();
                    if (ctl.get() > maximumPoolSize) {
                        break;
                    }
                    task = null;
                }

            } finally {
                //退出即工作线程数减1
                ctl.decrementAndGet();
            }
        }
    }

    private Runnable getTask() {

        for ( ; ; ) {
            try {
                Runnable c = null;
                if(ctl.get() > corePoolSize) {
                    //超时获取
                    c = workQueue.poll(keepAliveTime,TimeUnit.NANOSECONDS);

                } else {
                    //一直阻塞获取
                    c = workQueue.take();

                }
                return c;
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

核心就是

  1. 一个exeute()方法去控制流程。通过原子类的AtomicInteger保证线程数量正确变化。
  2. 一个addWorker()方法去创建一个Worker类。这个Worker类封装了Runnable和Thread。
  3. Worker类既可以当作一个任务,也可以当作一个线程。确实启动的线程执行的是worker自己的run。但是也就是这样,能够加入对阻塞队列获取的判断。并且获取不到任务的线程,超时就会退出for循环。
  4. getTask()方法 获取阻塞队列中方法,超时获取和阻塞获取。核心线程是阻塞获取,非核心线程是超时获取。
  5. 可以看出,核心线程和非核心线程都是普通Thread。就是根据对线程池中的线程数的判断,来实现非核心和核心的概念。

这个对比ThreadPoolExecutor,是很简略的。比如说addWorker方法中,使用了ReentrantLock 保证新建的线程正确加入到线程set中,保证不被GC。
再说Worker类,通过AQS,实现了一个不可重入的锁。保证线程池可以优雅的关闭。也就是正在执行任务的线程不被中断。


可以简单跑

package ThreeYue;

import java.util.concurrent.ArrayBlockingQueue;

public class Test {
    public static void main(String[] args) {
        Study38 study38 = new Study38(2,4,new ArrayBlockingQueue<Runnable>(5),10);
        for(int i = 0; i < 10; i++) {
            int taskNum = i;
            study38.execute(() -> {
                try {
                    System.out.println("任务编号:" + taskNum);
                    System.out.println("此时线程池中有线程:"+Thread.currentThread());
                    System.out.println("开始执行任务 " + taskNum);
                    Thread.sleep(1000);
                    System.out.println(taskNum + " 任务执行结束");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

            });
        }
    }
}

其实线程池还有其它功能,很多。比如可以将Runnable封装为Callable返回结果。待续

  移动开发 最新文章
Vue3装载axios和element-ui
android adb cmd
【xcode】Xcode常用快捷键与技巧
Android开发中的线程池使用
Java 和 Android 的 Base64
Android 测试文字编码格式
微信小程序支付
安卓权限记录
知乎之自动养号
【Android Jetpack】DataStore
上一篇文章      下一篇文章      查看所有文章
加:2022-03-17 22:19:09  更:2022-03-17 22:21:07 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/24 18:59:34-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码