Java入门系列-21-多线程

什么是线程

在操作系统中,一个应用程序的执行实例就是进程,进程有独立的内存空间和系统资源,在任务管理器中可以看到进程。

线程是CPU调度和分派的基本单位,也是进程中执行运算的最小单位,可完成一个独立的顺序控制流程,当然一个进程中可以有多个线程。

多线程:一个进程中同时运行了多个线程,每个线程用来完成不同的工作。多个线程交替占用CPU资源,并非真正的并行执行。

使用多线程能充分利用CPU的资源,简化编程模型,带来良好的用户体验。

一个进程启动后拥有一个主线程,主线程用于产生其他子线程,而且主线程必须最后完成执行,它执行各种关闭动作。

在Java中main()方法为主线程入口,下面使用 Thread 类查看主线程名。

public class MainThread {
    public static void main(String[] args) {
        //获取当前线程
        Thread t=Thread.currentThread();
        System.out.println("当前线程名字:"+t.getName());
        //自定义线程名字
        t.setName("MyThread");
        System.out.println("当前线程名字:"+t.getName());
    }
}

创建线程

在Java中创建线程有两种方式

1.继承 java.lang.Thread 类

2.实现 java.lang.Runnable 接口

1.继承 Thread 类创建线程

(1)定义MyThread类继承Thread类

(2)重写run()方法,编写线程执行体

public class MyThread extends Thread{

    //重写run方法
    @Override
    public void run() {
        for (int i = 1; i <= 10; i++) {
            System.out.println(Thread.currentThread().getName()+":"+i);
        }
    }
}

(3)创建线程对象,调用start()方法启动线程

public class TestMyThread {

    public static void main(String[] args) {
        MyThread myThread=new MyThread();
        //启动线程
        myThread.start();
    }
}

多个线程同时启动后是交替执行的,线程每次执行时长由分配的CPU时间片长度决定

修改 TestMyThread.java 观察多线程交替执行

public class TestMyThread {

    public static void main(String[] args) {
        MyThread myThread1=new MyThread();
        MyThread myThread2=new MyThread();
        myThread1.start();
        myThread2.start();
    }
}

多运行几次观察效果

启动线程能否直接调用 run()方法?

不能,调用run()方法只会是主线程执行。调用start()方法后,子线程执行run()方法,主线程和子线程并行交替执行。

2.实现 Runnable 接口创建线程

(1)定义MyRunnable类实现Runnable接口

(2)实现run()方法,编写线程执行体

public class MyRunnable implements Runnable{
    //实现 run方法
    @Override
    public void run() {
        for (int i = 1; i <= 10; i++) {
            System.out.println(Thread.currentThread().getName()+":"+i);
        }
    }
}

(3)创建线程对象,调用start()方法启动线程

public class TestMyRunnable {

    public static void main(String[] args) {
        Runnable runnable=new MyRunnable();
        //创建线程,传入runnable
        Thread t=new Thread(runnable);
        t.start();
    }
}

线程的生命周期

创建状态:线程创建完成,比如 MyThread thread=new MyThread

就绪状态:线程对象调用 start() 方法,线程会等待CPU分配执行时间,并没有立马执行

运行状态:线程分配到了执行时间,进入运行状态。线程在运行中发生礼让 (yield) 会回到就绪状态

阻塞状态:执行过程中遇到IO操作或代码 Thread.sleep(),阻塞后的线程不能直接回到运行状态,需要重新进入就绪状态等待资源的分配。

死亡状态:自然执行完毕或外部干涉终止线程

线程调度

线程调度指按照特定机制为多个线程分配CPU的使用权

线程调度常用方法

方法 说明
setPriority(int newPriority) 更改线程的优先级
static void sleep(long millis) 在指定的毫秒数内让当前正在执行的线程休眠
void join() 等待该线程终止
static void yield() 暂停当前正在执行的线程对象,并执行其他线程
void interrupt() 中断线程
boolean isAlive() 测试线程是否处于活动状态

线程优先级的设置

线程优先级由1~10表示,1最低,默认有限级为5。优先级高的线程获得CPU资源的概率较大。

public class TestPriority {

    public static void main(String[] args) {
        Thread t1=new Thread(new MyRunnable(),"线程A");
        Thread t2=new Thread(new MyRunnable(),"线程B");
        //最大优先级
        t1.setPriority(Thread.MAX_PRIORITY);
        //最小优先级
        t2.setPriority(Thread.MIN_PRIORITY);
        t1.start();
        t2.start();
    }
}

线程休眠

让线程暂时睡眠指定时长,线程进入阻塞状态,睡眠时间过后线程会再进入可运行状态。

休眠时长以毫秒为单位,调用sleep()方法需要处理 InterruptedException异常。

public class TestSleep {

    public static void main(String[] args) {
        for (int i = 1; i <= 10; i++) {
            System.out.println("第 "+i+" 秒");
            try {
                //让当前线程休眠1秒
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

强制运行

使用 join() 方法实现,可以认为是线程的插队,会先强制执行插队的线程。

public class JoinThread implements Runnable{

    @Override
    public void run() {
        for (int i = 1; i <=10; i++) {
            System.out.println("线程名:"+Thread.currentThread().getName()+" i:"+i);
        }
        System.out.println("插队线程执行完毕!");
    }
}
public class TestJoin {

    public static void main(String[] args) {
        Thread joinThread=new Thread(new JoinThread(),"插队的线程");
        //启动后与主线程交替执行
        joinThread.start();
        for (int i = 1; i <= 10; i++) {
            if (i==5) {
                try {
                    System.out.println("====开始插队强制执行====");
                    joinThread.join();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            System.out.println("线程名:"+Thread.currentThread().getName()+" i:"+i);
        }
        System.out.println("主线程执行完毕!");
    }
}

最一开始执行,主线程 main 和 "插队的线程"是交替执行。当主线程的循环到第5次的时候,调用 "插队的线程"的join方法,开始强制执行"插队的线程",待"插队的线程"执行完后,才继续恢复 main 线程的循环。

线程礼让

使用 yield() 方法实现,礼让后会暂停当前线程,转为就绪状态,其他具有相同优先级的线程获得运行机会。

下面我们实现Runnable接口,在run方法中实现礼让,创建两个线程,达到某种条件时礼让。

public class YieldThread implements Runnable{

    @Override
    public void run() {
        for (int i = 1; i <= 10; i++) {
            System.out.println("线程名:"+Thread.currentThread().getName()+" i:"+i);
            //当前线程执行到5后发生礼让
            if (i==5) {
                System.out.println(Thread.currentThread().getName()+" 礼让:");
                Thread.yield();
            }
        }
    }
}
public class TestYield {

    public static void main(String[] args) {
        Thread t1=new Thread(new YieldThread(),"A");
        Thread t2=new Thread(new YieldThread(),"B");
        t1.start();
        t2.start();
    }
}

只是提供一种可能,不能保证一定会实现礼让

线程同步

首先看一个多线共享同一个资源引发的问题

仓库有10个苹果,小明、小红、小亮每次可以从仓库中拿1个苹果,拿完苹果后仓库中的苹果数量-1。

先编写仓库资源类,实现接口

//这个实现类将被多个线程对象共享
public class ResourceThread implements Runnable{
    private int num=10;
    @Override
    public void run() {
        while(true) {
            if (num<=0) {
                break;
            }
            num--;
            try {
                Thread.sleep(300);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName()+"拿走一个,还剩余:"+num);
        }
    }
}

编写测试类,创建两个线程对象,共享同一个资源

public class TestResource {

    public static void main(String[] args) {
        ResourceThread resource=new ResourceThread();
        //使用同一个Runnable实现类对象
        Thread t1=new Thread(resource,"小明");
        Thread t2=new Thread(resource,"小红");
        Thread t3=new Thread(resource,"小亮");
        t1.start();
        t2.start();
        t3.start();
    }
}

运行后我们发现,每次拿完苹果后的剩余数量出现了问题,使用同步方法可以解决这个问题。

语法:

访问修饰符 synchronized 返回类型 方法名(参数列表){
    ……
}

synchronized 就是为当前的线程声明一个锁

修改 ResourceThread.java 实现同步

//这个实现类将被多个线程对象共享
public class ResourceThread implements Runnable{
    private int num=10;
    private boolean isHave=true;
    @Override
    public void run() {
        while(isHave) {
            take();
        }
    }
    //同步方法
    public synchronized void take() {
        if (num<=0) {
            isHave=false;
            return;
        }
        num--;
        try {
            Thread.sleep(300);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName()+"拿走一个,还剩余:"+num);
    }
}

实现同步的第二种方式同步代码块

语法:

synchronized(syncObject){
    //需要同步的代码
}

syncObject为需同步的对象,通常为this

修改 ResourceThread.java 改为同步代码块

//这个实现类将被多个线程对象共享
public class ResourceThread implements Runnable{
    private int num=10;
    private boolean isHave=true;
    @Override
    public void run() {
        while(isHave) {
            synchronized(this) {
                if (num<=0) {
                    isHave=false;
                    return;
                }
                num--;
                try {
                    Thread.sleep(300);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println(Thread.currentThread().getName()+"拿走一个,还剩余:"+num);
            }
        }
    }
}

原文地址:https://www.cnblogs.com/AIThink/p/9858875.html

时间: 2024-11-07 16:15:55

Java入门系列-21-多线程的相关文章

【小白的java成长系列】——多线程初识(多人买票问题)

本来这节内容是要到后面来说的,因为最近在弄并发的问题,推荐一本书<java并发编程实战>,深入的讲解了多线程问题的.本人最近也刚好在看这本书,还不错的~ 多线程的相关概念,就不用说了的,自己可以去网上查找,有一大堆关于它的讲解~ 先来看看买票的程序: package me.javen.thread.one; public class TicketDemo { public static void main(String[] args) { // 使用Thread类的方式 // TicketTh

Java入门系列:实例讲解ArrayList用法

本文通过实例讲解Java中如何使用ArrayList类. Java.util.ArrayList类是一个动态数组类型,也就是说,ArrayList对象既有数组的特征,也有链表的特征.可以随时从链表中添加或删除一个元素.ArrayList实现了List接口. 大家知道,数组是静态的,数组被初始化之后,数组长度就不能再改变了.ArrayList是可以动态改变大小的.那么,什么时候使用Array(数组),什么时候使用ArrayList?答案是:当我们不知道到底有多少个数据元素的时候,就可使用Array

[JAVA &#183; 初级]:21.多线程

概述 程序:Program,是一个静态的概念 进程:Process,是一个动态的概念 进程是程序的一次动态执行过程, 占用特定的地址空间. 每个进程都是独立的,由3部分组成cpu,data,code 缺点:内存的浪费,cpu的负担 线程:Thread,是进程中一个"单一的连续控制流程"  (a single sequential flow ofcontrol)/执行路径 线程又被称为轻量级进程(lightweight process). Threads run at the same

java并发系列(一)-----多线程简介、创建以及生命周期

进程.线程与任务进程:程序的运行实例.打开电脑的任务管理器,如下: 正在运行的360浏览器就是一个进程.运行一个java程序的实质是启动一个java虚拟机进程,也就是说一个运行的java程序就是一个java虚拟机进程.进程是程序向操作系统申请资源(如内存空间和文件句柄)的基本单位. 线程:是进程中可独立执行的最小单位,并且不拥有资源.进程相当于工厂老板,整个工厂的机器都是属于老板的,但是工厂里面的活都是由工人完成的. 任务:线程所要完成的计算就被称为任务,特定的线程总是执行特定的任务. java

Java入门系列之字符串特性(二)

前言 上一节我们讲解到字符串本质上就是字符数组,同时详细讲解了字符串判断相等需要注意的地方,本节我们来深入探讨字符串特性,下面我们一起来看看. 不可变性 我们依然借助初始化字符串的方式来探讨字符串的不可变性,如下: String str = "Jeffcky"; System.out.println(str); 上述我们通过字面量的方式来创建字符串,接下来我们对字符串str进行如下操作: String str = "Jeffcky"; str.substring(0

Java入门系列之StringBuilder、StringBuffer(三)

前言 上一节我们讲解了字符串的特性,除了字符串类外,还有两个我们也会经常用到的类,那就是StringBuffer和StringBuilder.因为字符串不可变,所以我们每次对字符串的修改比如通过连接concat.trim等都会创建一个新的字符串对象,那么我们如何在不创建字符串垃圾(大量临时的字符串)的 情况下操作字符串呢?答案则是使用StringBuffer和StringBuilder,StringBuffer是旧类,但是在Java 5中新增了StringBuilder,并且在Enum,Gene

Java入门系列之包装类(四)

前言 上一节我们讲解了StringBuilder VS StringBuffer以及二者区别,本节我们来讲解包装类. 包装类 我们知道在Java中有8中基本数据类型,分为数值类型:byte.short.int.long.float.double.字符类型:char.布尔类型:bool,那么什么是包装类呢?包装类是8种基本数据类型的对象表示,而且8种包装类和字符串对象一样是不可变且final(不可通过继承或扩展破坏不可变性)的.我们通过查看int的包装类型Integer可知,如下: 如下为基本数据

Java入门系列之集合HashMap源码分析(十四)

前言 我们知道在Java 8中对于HashMap引入了红黑树从而提高操作性能,由于在上一节我们已经通过图解方式分析了红黑树原理,所以在接下来我们将更多精力投入到解析原理而不是算法本身,HashMap在Java中是使用比较频繁的键值对数据类型,所以我们非常有必要详细去分析背后的具体实现原理,无论是C#还是Java原理解析,从不打算一行行代码解释,我认为最重要的是设计思路,重要的地方可能会多啰嗦两句. HashMap原理分析 我们由浅入深,循序渐进,首先了解下在HashMap中定义的几个属性,稍后会

Java入门系列:处理Json格式数据

本节主要讲解: 1)json格式数据处理方法 2)第三方工具包的使用方法 3)java集合数据类型 [项目任务] 编写一个程序,显示未来的天气信息. [知识点解析] 为了方便后面代码的分析,先需要掌握几个相关的知识. 1.什么是json格式数据 从结构上看,我们所见到的所有的数据(data)最终都可以分解成三种类型: 第一种类型是标量(scalar),也就是一个单独的字符串(string)或数字(numbers),比如"北京"这个单独的词. 第二种类型是序列(sequence),也就是