关于java:话说-线程切换线程数设置

46次阅读

共计 3589 个字符，预计需要花费 9 分钟才能阅读完成。

线程的切换受操作系统的调度管制

简略流程是这样的：

操作系统让 cpu 执行线程 1
线程 1 执行到指令 003 的时候操作系统让 cpu 执行线程 2
cpu 会将线程 1 的执行半成品放到缓存中
cpu 接着执行线程 2
cpu 执行线程 2 的 004 指令的时候操作系统又让 cpu 执行线程 1
cpu 从缓存拿出线程 1 的残次品接着执行
cpu 就是一个无脑的计算中心它不论调度只管计算（像极了咱们程序员）
而操作系统是负责调度的（像极了咱们的领导）
在这里应该能发现一个点那就是：线程的切换是须要消耗操作系统资源的（领导使唤你干活儿必定要节约领导工夫和精力）

一个 cpu 在一个时间段只能跑一个线程，我单个 cpu 设置多个线程有意义吗？

当然有意义了，你只有一个脑子（CPU），你除了想你女朋友（如果你有），你还会想的姑娘吗~~（会的）

为什么呢，因为有时候你女朋友不肯定在耗费你的脑子线程也是如此，比方一个线程 01 须要进行数据库数据加载，这时候它是不耗费 cpu 的，他是在耗费网络 IO,CPU 多值钱呀，必定不能闲暇，所以在线程 01 加载数据库数据的时候，就能够让 CPU 进行线程 02 的计算操作

CPU 密集型：

CPU 密集型也叫计算密集型，简略说就是大部分时候 CPU 应用在 100%，而读写磁盘 / 内存工夫很短

比方大量数据计算的，进行数据分析的，也可能是 CPU 性能极差的而磁盘 / 内存性能很好的状况

IO 密集型：

IO 密集型跟 CPU 密集型相同，大部分工夫 CPU 使用率很小，而读写磁盘 / 内存占用很大工夫

比方读数据库比拟多的，网络申请比拟多的，也可能是磁盘 / 内存品质差的的状况

当然不是了，线程数太大了，CPU 就不干活了，只用来切换线程了

就比方程序员，一天内负责两个我的项目的开发，上午在公司 9 楼项目组，下午在公司 6 楼项目组，

这个还能够承受，如果开发 100 个呢？9 点在 1 楼，刚坐下就要去 2 楼，2 楼刚坐下又要去三楼，这一天工夫都用在换楼层了

写个小例子感受一下：

public class NumTest {
    // 一有 1 亿条数据的数组
    public static  double[] arr = new double[100000000];
    public static void main(String[] args) throws InterruptedException {
        // 初始化
        Random r = new Random();
        for (int i = 0; i < arr.length; i++) {arr[i] =r.nextInt(10);
        }
        // 单线程计算
        getSum01();
        // 2 线程计算
        getSum02();
        // 多个线程计算
        getSum03();}



    // 单线程计算 sum
    private static void getSum01() {long start = System.currentTimeMillis();
        double sum = 0;
        // 遍历求和
        for (int i = 0; i <arr.length ; i++) {sum = sum+arr[i];
        }
        long end = System.currentTimeMillis();
        // 输入日志
        System.out.println("一个线程计算 耗时:"+(end-start) + "毫秒，"  +"计算结果:"+sum);
    }

    /**
     * 2 个线程计算 sum
     */
    static double sum01,sum02;
    private static void getSum02() throws InterruptedException {
        // 第一个线程 计算 0 到一半
        Thread thread01 = new Thread(() -> {for (int i = 0; i < arr.length / 2; i++) {sum01 = sum01 + arr[i];
            }
        });
        // 第二个线程 计算一半到 length
        Thread thread02 = new Thread(() -> {for (int i = arr.length / 2; i < arr.length; i++) {sum02 = sum02 + arr[i];
            }
        });
        long start = System.currentTimeMillis();
        thread01.start();
        thread02.start();
        // join 到主线程  阻塞
        thread01.join();
        thread02.join();
        // 执行完之后 求一下两个线程别离求和的和
        double  sum =sum01+sum02;
        long end = System.currentTimeMillis();
        // 打印日志
        System.out.println("2 个线程计算 耗时:"+(end-start) + "毫秒，"  +"计算结果:"+sum);
    }

    /**
     * 多个线程计算
     * @throws InterruptedException
     */
    private static void getSum03() throws InterruptedException {
        // 10 个线程 可自行调节
        int ThreadNum = 1000;
        // 创立 ThreadNum 个长度的 long 数组 存储各个线程的求和后果
        double[] sums = new double[ThreadNum];
        // 存储多个线程
        Thread[]  threads = new Thread[ThreadNum];
        // 每个线程计算的数字个数
        final int segCount = arr.length/ThreadNum;
        CountDownLatch cdl = new CountDownLatch(ThreadNum);
        // 创立多个线程
        for (int i = 0; i < ThreadNum; i++) {
            int m = i;
            Thread thread = new Thread(() -> {
                // 每个线程执计算逻辑
                for (int j = segCount*m; j <segCount*(m+1) && j < arr.length; j++) {sums[m]+=arr[j];
                }
                cdl.countDown();});
            threads[i] = thread;
        }
        long start = System.currentTimeMillis();
        // 全副启动
        for (int i = 0; i < threads.length; i++) {threads[i].start();}
        cdl.await();
        // 最初求和
        double sum = 0;
        for (int i = 0; i < sums.length; i++) {sum+=sums[i];
        }
        long end = System.currentTimeMillis();
        // 打印日志
        System.out.println("多个线程计算 耗时:"+(end-start) + "毫秒，"  +"计算结果:"+sum);
    }
}

输入后果：一个线程计算 耗时:177 毫秒，计算结果:4.50063291E8
2 个线程计算 耗时:99 毫秒，计算结果:4.50063291E8
多个线程计算 耗时:162 毫秒，计算结果:4.50063291E8

能够看进去 2 个线程比一个执行快然而 1000 个不肯定比 2 个执行快因为 1000 个线程上下文切换就要破费很多资源

实际中多少都是通过压测来确定的然而压测初始值是能够本人推算一个的
怎么推算比方我方才那个例子：我电脑 4 核我想让每个核一个线程
这样切换就少了我把 ThreadNum 设置为 4
输入后果：

一个线程计算 耗时:177 毫秒，计算结果:4.49997398E8
2 个线程计算 耗时:99 毫秒，计算结果:4.49997398E8
多个线程计算 耗时:79 毫秒，计算结果:4.49997398E8

那咱们有多少核就设置多少个线程？
不是的！
首先，cpu 不是只为你一个人服务的除了你还有很多别的过程须要 cpu
个别说的充分利用 CPU 不是说都用到 100% 咱们还要留一部分 cpu 进行利用，跟你下班一样，地铁 30 分钟 + 走路 10 分钟到公司，你如果 9 点下班你会 8 点 20 出门吗必定会早一点出门留点儿余地
线程数量设定公式
Nthread = Ncpu Ucpu (1+W/C)
Ncpu : 处理器的核数 java 能够这样获取：
```
 System.out.println(Runtime.getRuntime().availableProcessors());
```

Ucpu: 冀望 CPU 的利用率在 0 到 1 之间

W/C: 是等待时间与计算工夫的比率 wait/compute

能够看进去：
cpu 合数和 cpu 使用率确定的状况下等待时间（W）越长能够设置的线程数就应该越多

如果 c(计算工夫)占比很大也就是 w /c ≈ 0 那适合的线程数就等于 NcpuxUcpux1

4 中说的 w 和 c 我怎么晓得的？
这些值呢，一般来说通过工具 (profiler) 进行测算

java 最罕用的是 JProfiler (免费的) 本地开发测试

如果曾经部署到服务器上了能够用阿里开源的 Arthas 做统计

后边会简略写一下:JProfiler Arthas 的应用

有问题能够留言哦，也能够公众号留言（回复快）：

正文完