Java多线程详解_java支持多线程

Java多线程详解_java支持多线程一、线程生命周期一个线程被实例化完成,到线程销毁的中间过程1.新生态:New一个线程对象被实例化完成,但是没有做任何操作2.就绪态度:Ready一个线程被开启,并且开始抢占CPU时间3.运

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

一、线程生命周期

一个线程被实例化完成,到线程销毁的中间过程

1.新生态:New

一个线程对象被实例化完成,但是没有做任何操作

2.就绪态度:Ready

一个线程被开启,并且开始抢占CPU时间

3.运行态:Run

一个进程抢到的CPU时间片,并且开始执行线程中的逻辑

4.阻塞态:Interrupt

一个线程运行中,放弃了已经获取的CPU时间片,不再参与CPU时间片的抢占,此时线程处于挂起状态

5.死亡态:Dead

一个线程对象需要被销毁

Java多线程详解_java支持多线程

二、简单创建线程的两种方式

1.继承Thread类来创建

步骤如下:

  • 定义Thread类的子类,并重写该类的run()方法
  • 创建Thread子类的实例、
  • 调用线程的start()方法启动线程
/**
 * 1.继承Thread类,自定义线程类
 */
class MyThread extends Thread {
    /**
     * 重写run方法,将并发任务写入
     */
    @Override
    public void run() {
        for (int i = 0; i < 10; i++) {
            System.out.println("我是线程中run的方法,执行次数" + (i + 1));
        }
    }

    /**
     * 线程的命名
     */
    public MyThread(String name) {
        //在可以在实例化线程时向Thread类的构造方法传参
        super(name);
        
        //也可以调用set方法
        this.setName(name);
    }
}

2.实现Runnable接口创建

步骤如下:

  • 定义Runnable接口的实现类,重写run()方法
  • 创建Runnable实现类的实例,并在实例化Thread类时传入
  • 调用线程对象的start()方法来启动线程
/**
 * 2.通过runablele接口
 * @return
 */
Thread getRunable() {
    Runnable runnable = () -> {
        for (int i = 0; i < 10; i++) {
            System.out.println("我是线程中Runable的方法,执行次数" + (i + 1));
        }
    };
    return new Thread(runnable);
}

三、Thread线程类常用方法

Thread类有以下方法:

  • String getName():返回该线程的名称。

  • void setName(String name):设置线程名称

  • int getPriority():获取线程的优先级。

  • void setPriority(int newPriority):修改线程的优先级。

  • boolean isDaemon():获取该线程是否为守护线程。

  • void setDaemon(boolean on):将该线程标记为守护线程或用户线程。

  • static void sleep(long millis):线程阻塞

  • void interrupt():中断线程。

  • static void yield():暂停当前正在执行的线程对象,并执行其他线程。

  • void join():等待该线程终止。

  • void run():线程的执行体

  • void start() :启动线程

  • 从Object类继承来的方法:void notify();void wait()

下面对常用方法做一下简略的演示:

1.sleep 阻塞

Thread.sleep(times)

使当前线程从Running状态放弃处理器进入Block状态,休眠times毫秒,再返回Runnable状态。

/**
 * 1.线程阻塞
 */
void setSleect(){
    new Thread(() -> {
        for (int i = 0; i < 3; i++) {
            try {
                Thread.sleep(1000);
                System.out.println("我是要阻塞的线程,执行次数" + (i + 1));
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }, "sleepThread").start();
}

2.priority 优先级

setPriority(int newPriority)

按1-10为线程的时间片分配机会设置优先级,优先级越高,执行概率越高

按以下实例,最终结果是线程1比线程2更早循环完100次

/**
 * 2.设置时间优先级
 */
void setPriority() {
    Runnable runnable = () -> {
        for (int i = 0; i < 100; i++) {
            System.out.println(Thread.currentThread().getName() + ":执行第" + (i + 1) + "次");
        }
    };

    Thread thread1 = new Thread(runnable, "线程1");
    Thread thread2 = new Thread(runnable, "线程2");

    //设置优先级
    thread1.setPriority(10);
    thread2.setPriority(1);

    //启动
    thread1.start();
    thread2.start();
}

3.yield 线程礼让

Thread.yield()

让出当前线程对象分配到的cup时间片,执行其他线程。

/**
 * 设置线程礼让
 */
void setThreadYield() {
    Thread thread1 = new Thread(getRunable(10), "线程1");
    Thread thread2 = new Thread(getRunable(35), "线程2");

    //启动
    thread1.start();
    thread2.start();
}

Runnable getRunable(int yieldNum) {
    return new Runnable() {
        @Override
        public void run() {
            for (int i = 0; i < 100; i++) {
                //设置在第几个数字的时候进行礼让
                if (i == yieldNum) {
                    Thread.yield();
                    System.out.println("我让位!");
                }
                System.out.println(Thread.currentThread().getName() + ":执行第" + (i + 1) + "次");

            }
        }
    };
}

3. join 等待线程

Thread.join()

让当前线程进入等待队列,带某线程执行完毕后当前线程再开始执行,可以理解为将两个线程的关系由并行变为串行,但是并不影响其他线程的并行执行

/**
 * join
 */
void getJoin() {
    Thread t1 = new Thread(() -> {
        System.out.println("t1执行了!");

        for (int i = 0; i < 10; i++) {
            System.out.println("t1:" + i);
        }
    });

    Thread t2 = new Thread(() -> {
        System.out.println("t2等待t1执行完毕....");
        try {
            t1.join();

            for (int i = 0; i < 10; i++) {
                System.out.println("t2:" + i);
            }

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

        System.out.println("t2执行了!");
    });

    Thread t3 = new Thread(() -> {
        System.out.println("t3不等待t1执行完毕....");
        for (int i = 0; i < 10; i++) {
            System.out.println("t3:" + i);
        }
        System.out.println("t3执行了!");
    });

    t1.start();
    t3.start();
    t2.start();
}

四、创建几个线程合适?

对于CPU密集型的计算场景,理论上线程的数量=CPU核数就是最合适的。不过在工程上,线程的数量一般会设置为CPU核数+1,这样的话,当线程因为偶尔的内存页失效或其他原因导致阻塞时,这个额外的线程可以顶上,从而保证CPU的利用率

对于I/O密集型的计算场景,最佳线程数=1+(I/O耗时/CPU耗时)

针对多核CPU,我目前见过两种比较合理的公式:

  1. 最佳线程数=CPU核数×[1+(I/O耗时/CPU耗时)]
  2. 线程数=CPU核数×目标CPU利用率×(1+平均等待时间/平均工作时间)

参考:

java多线程:创建多少线程才合适?

线程数究竟设多少合适

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/170823.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • uboot中的mmc命令

    uboot中的mmc命令

    2021年11月29日
  • SpringCloud确保服务只能通过gateway转发访问,禁止直接调用接口访问

    点击上方“全栈程序员社区”,星标公众号 重磅干货,第一时间送达 作者:Hpsyche blog.csdn.net/Hpsyche/article/details/102926010…

  • puppeteer爬虫教程_python爬虫入门最好书籍

    puppeteer爬虫教程_python爬虫入门最好书籍译者按: 本文通过简单的例子介绍如何使用Puppeteer来爬取网页数据,特别是用谷歌开发者工具获取元素选择器值得学习。原文: AGuidetoAutomating&am

  • QT计算器 之 大数运算「建议收藏」

    QT计算器 之 大数运算「建议收藏」1、简介:计算器是我们生活中很常见的东西,它可以由多种语言多种方式来实现,今天我想讲的是基于C++语言,由QT实现的可以计算大数的简单计算器。2、作品演示:(1)简单四则运算(2)大数运算3、重点原理讲解(1)四则运算如何实现(2)大数的加减乘除4、代码主体框架1个主函数;两个类:一个calculator类,实现了对界面的布局,其实这个布局很简单,就设置

  • myeclipse 注册码(8.5版本)「建议收藏」

    myeclipse 注册码(8.5版本)「建议收藏」ID:myEclipse8.5code:zLR8ZC-855575-75526156215269972ID:myEclipse8.51code:zLR8ZC-855575-7552615625006863ID:myEclipse8.52code:zLR8ZC-855575-7552615625006864ID:myEclipse8.53code…

  • kafka队列模式_redis消息队列和mq

    kafka队列模式_redis消息队列和mq一、消息队列概述消息队列中间件是分布式系统中重要的组件,主要解决应用解耦,异步消息,流量削锋等问题,实现高性能,高可用,可伸缩和最终一致性架构。目前使用较多的消息队列有ActiveMQ,RabbitMQ,ZeroMQ,Kafka,MetaMQ,RocketMQ二、消息队列应用场景以下介绍消息队列在实际应用中常用的使用场景。异步处理,应用解耦,流量削锋和消息通讯四个场景。2.1异步处理场景说明:用户注册后,需要发注册邮件和注册短信。传统的做法有两种1.串行的方式;2.并行方式a、串行方式:将注册

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号