首页 > 编程语言 >JAVA线程

JAVA线程

时间：2022-09-05 20:58:09浏览次数：181  
标签：JAVA Thread class 线程 new run public

01、基本概念：程序、进程、线程

  • 程序（program）：为完成特定任务、用某种语言编写的一组指令的集合。即指一段静态的代码，静态对象。
  • 进程（process）：程序的一次执行过程，或是正在运行的一个程序。是一个动态的过程：有它自身的产生、存在和消亡的过程----生命周期
    • 如：运行中的QQ，运行中的MP3播放器程序是静态的，进程是动态的
    • 进程作为资源分配的单位，系统在运行时会为每个进程分配不同的内存区域
  • 线程（Thread），进程可进一步细化为线程，是一个程序内部的一条执行路径
    • 若一个进程同一时间并行执行多个线程，就是支持多线程的
    • 线程是调度和执行的单位，每个线程拥有独立运行的运行栈和程序计数器（PC），线程切换的开销小。
    • 一个进程中的多个线程相同的内存单元/内存地址空间----->它们从同一堆中分配对象，可以访问相同的变量和对象。这就使得线程间通信更简便

单核CPU和多核CPU

单核CPU，其实是一种假的多线程，因为在一个时间单元内，也只能执行一个线程的任务，例如：虽然有很多车道，但是收费站只有一个工作人员在收费，只有收了费才能通过，那么CPU就好比收费人员。如果有个人不想交钱，那么收费人员可以把他“挂起”。但是因为CPU时间单元特别短，所以无法察觉。

如果是多核CPU，才能更好的发挥多线程的效率。（现在的服务器都是多核的）

一个JAVA应用程序java.exe，其实至少有三个线程：main()主线程、gc()垃圾回收线程、异常处理线程。当然如果发生异常，会影响主线程。

并行与并发

并行：多个CPU同时执行多个任务。

并发：一个CPU（采用时间片）同时执行多个任务。

使用多线程的优点

多线程程序的优点

  1. 提高应用程序的响应。对图形化界面更有意义，可增强用户体验
  2. 提高计算机系统的CPU的利用率
  3. 改善程序结构。将长而复杂的进程分为多个线程，独立运行，利于理解和修改

02、线程的创建和使用

2.1 线程的创建和启动

Java语言的JVM允许程序运行多个线程，它通过java.lang.Thread类来体现。

Thread类的特性

  • 每个线程都是通过某个特定Thread对象的run()方法来完成这个操作，经常把run()方法的主体成为线程体

  • 通过该Thread对象的start()方法来启动这个线程，而非直接调用run()

2.2 Thread类

  • Thread()：创建新的Thread对象

  • Thread(String threadname)：创建线程并指定线程实例名

  • Thread(Runnable target)：指定创建线程的目标对象，它实现了Runnable接口中的run方法

  • Thread(Runnable target，String name)：创建新的Thread对象

2.3 API中的创建进程的两种方式

JDK1.5之前创建执行线程的两种方法：

  • 继承Thread类的方法
  • 实现Runnable接口的方法
2.3.1 创建多线程的方式一：继承Thread类的方法

MyThread.java

package com.company;

//1、创建一个继承Thread类的子类
class MyThread extends Thread{
    //2、重写Thread类的run()
    @Override
    public void run() {
        for(int count=1;count<100;count++){
            if(count%=2){
                System.out.println(count);
            }
        }
    }
}

public class Main {

    public static void main(String[] args) {
        // 3、创建Thread的子对象
        MyThread thread1=new MyThread();

        // 4、通过此对象调用start():1、启动当前进程2、调用当前进程的run()
        thread1.start();

        //如下操作仍在main线程中进行
        for(int count=1;count<100;count++){
            if(count%2==0){
                System.out.println(count+"************main()******");
            }
        }
    }
}

　运行结果如下：

 子进程创建与执行过程

 

　

 

2.3.2 创建过程中的两个问题说明
package com.company;

//1、创建一个继承Thread类的子类
class MyThread extends Thread{
    //2、重写Thread类的run()
    @Override
    public void run() {
        for(int count=1;count<10;count++){
            if(count==2){
                System.out.println(Thread.currentThread().getName()+":"+count);
            }
        }
    }
}

public class Main {

    public static void main(String[] args) {
        // 3、创建Thread的子对象
        MyThread thread1=new MyThread();

        // 4、通过此对象调用start():1、启动当前进程2、调用当前进程的run()
        thread1.start();

        MyThread thread2=new MyThread();
        thread2.start();

        //如下操作仍在main线程中进行
        for(int count=1;count<10;count++){
            if(count%2==0){
                System.out.println(Thread.currentThread().getName()+":"+count+"************main()******");
            }
        }
    }
}

　启动两个线程的

写法一：

MyThread.java

package com.company;

//1、创建一个继承Thread类的子类
class MyThread extends Thread{
    //2、重写Thread类的run()
    @Override
    public void run() {
        for(int count=1;count<10;count++){
            if(count%2==0){
                System.out.println(Thread.currentThread().getName()+":"+count);
            }
        }
    }
}
class  MyThread2 extends Thread{
    @Override
    public void run() {
        for(int count=0;count<10;count++){
            if(count%2==0){
                System.out.println(Thread.currentThread().getName()+":"+count);
            }
        }
    }
}

public class Main {

    public static void main(String[] args) {
        // 3、创建Thread的子对象
        MyThread thread1=new MyThread();

        // 4、通过此对象调用start():1、启动当前进程2、调用当前进程的run()
        thread1.start();

        MyThread2 myThread2 = new MyThread2();
        myThread2.start();
    }
}

 写法二：

Main.java

package com.company;

public class Main {

    public static void main(String[] args) {
        new Thread(){
            @Override
            public void run() {
                for(int count=0;count<10;count++){
                    if(count%2==0){
                        System.out.println(Thread.currentThread().getName()+":"+count);
                    }
                }
            }
        }.start();

        new Thread(){
            @Override
            public void run() {
                for(int count=0;count<10;count++){
                    if(count%2==0){
                        System.out.println(Thread.currentThread().getName()+":"+count);
                    }
                }
            }
        }.start();
    }
}

2.3.3 Thread类的相关方法　　

package com.company;

/*
 * 测试Thread的常用方法
 * 1、start():启动当前进程，执行当前进程的run()
 * 2、run():通常需要重写Thread类中的此方法，将创建的线程要执行的操作声明在此方法中
 * 3、currentThread():静态方法，返回当前代码执行的线程
 * 4、getName():获取当前进程的进程名
 * 5、setName():设置当前进程的进程名
 * 6、yield():释放当前CPU的执行权
 * 7、join():在线程a中调用线程b的join(),此时线程a就进入了阻塞状态，直到线程b完全执行完以后，线程a才结束阻塞状态
 * 8、stop():已过时。当执行此方法时，强制结束当前进程
 * 9、sleep(long millitime):让当前进程“睡眠”指定时间的millitime毫秒。在指定的millitime毫秒时间内，当前进程是阻塞状态的
 * 10、isAlive():返回boolean,判断线程是否还活着
 */
class HelloThread extends Thread{
    @Override
    public void run() {
        for(int count=0;count<10;count++){

            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

            if(count%2==0){
                System.out.println(Thread.currentThread().getName() + ":"+count);
            }
        }
    }

    public HelloThread(String name) {
        super(name);
    }
}
public class Main {

    public static void main(String[] args) {
        HelloThread helloThread1=new HelloThread("Thread:1");
        helloThread1.start();

        //给主线程命名
        Thread.currentThread().setName("主线程");

        for(int count=0;count<100;count++){
            if(count%2==0){
                System.out.println(Thread.currentThread().getName()+":"+count);
            }

            if(count==20){
                try{
                    helloThread1.join();
                }catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
        System.out.println(helloThread1.isAlive());
    }
}

2.3.4、线程的调度　

  • 调度策略
    • 时间片

    • 抢占式：高优先级的线程抢占CPU
  • Java的调度方法
    • 同优先级线程组成先进先出队列（先到先服务），使用时间片策略
    • 对于高优先级，使用优先调度的抢占式策略

2.3.5、线程的优先级

package com.company;

class HelloThread extends Thread{
    @Override
    public void run() {
        for(int count=0;count<10;count++){

            if(count%2==0){
                System.out.println(Thread.currentThread().getName() +getPriority()+ ":"+count);
            }
        }
    }

    public HelloThread(String name) {
        super(name);
    }
}
public class Main {

    public static void main(String[] args) {
        HelloThread helloThread1=new HelloThread("Thread:1");
        helloThread1.start();

        helloThread1.setPriority(Thread.MAX_PRIORITY);
        //给主线程命名
        Thread.currentThread().setName("主线程");

        for(int count=0;count<100;count++){
            if(count%2==0){
                System.out.println(Thread.currentThread().getName()+":"+count);
            }
        }
        System.out.println(helloThread1.isAlive());
    }
}

　设置helloThread1的优先级为最大优先级，执行结果如下：

2.3.6 创建多线程的方式二：实现Runnable接口

package com.company;

/*
 *创建多线程的方式二:实现Runnable接口
 * 1、创建一个实现了Runnable接口的类
 * 2、实现类去实现Runnable中的抽象方法:run()
 * 3、创建实现类的对象
 * 4、将此对象作为参数传递到Thread类的构造器中，创建Thread类的方法
 * 5、通过Thread类的对象调用start()
 */
class HelloThread implements Runnable{
    @Override
    public void run() {
        for(int count=0;count<10;count++){

            if(count%2==0){
                System.out.println(Thread.currentThread().getName() + ":"+count);
            }
        }
    }
}
public class Main {
    public static void main(String[] args) {
        //3、 创建实现类的对象
        HelloThread helloThread1= new HelloThread();
        //4、将此对象作为参数传递到Thread类的构造器中，创建Thread类的对象
        Thread t1=new Thread(helloThread1);
        //5、通过Thread类的对象调用start():1、启动线程2、调用当前线程的run() -->调用Runnable类型的target的run()
        t1.start();

        // 再启动一个线程，遍历100以内的偶数
        Thread t2=new Thread(helloThread1);
        t2.setName("线程2");
        t2.start();

    }
}

2.3.7 继承方式和实现接口方式的联系与区别

比较创建进程的两种方式：

开发中：优先选择：实现Runnable接口的方式

原因1：实现的方式没有类的单继承性的局限性

原因2：实现的方式更适合来处理多个线程有共享数据的情况

联系：public class Thread implements Runnable

相同点：两种方式都需要重写run()方法，将线程要执行的逻辑声明在run()中　

2.3.8  线程的分类

JAVA中的线程分为两类：一种是守护进程，一种是用户进程

  • 它们在几乎每个方面都是相同的，唯一的区别在于判断JVM何时离开
  • 守护进程是用来服务用户进程的，通过在start()方法前调用**thread.setDaemon(true)**可以把一个用户线程变成一个用户进程
  • Java垃圾回收就是一个典型的守护线程
  • 若JVM中都是守护线程，当前JVM将退出

03、线程的生命周期

JDK中用Thread.State类定义了线程的几种状态

  • 新建：当一个Thread类或其子类的对象被声明并创建时，新生的线程对象处于新建状态
  • 就绪：处于新建状态的线程被Start()后，将进入线程队列等待CPU时间片，此时它已具备了运行的条件，只是没分配到CPU资源
  • 运行：当就绪的线程被调度并获取CPU资源时，便进入运行状态，run()方法定义了线程的操作和功能
  • 阻塞：在某种特殊情况下，被人为挂起或执行输入输出操作时，让出CPU并临时中止自己的执行，进入阻塞状态
  • 死亡：线程完成了它的全部工作或线程被提前强制性中止或出现异常导致结束

04、线程的同步

1、多个线程的问题

多个线程执行的不确定性会引起执行结果的不稳定

多个线程对账本的共享会造成操作的不完整性，会破坏数据

 

 

 

模拟火车站售票程序，三个窗口卖票

package com.company;

class Windows1 implements Runnable{
    private int ticket=100;
    @Override
    public void run() {
        while(true){
            if(ticket>0){
                System.out.println(Thread.currentThread().getName() + ":卖票，票号为："+ticket);
                ticket --;
            }else{
                break;
            }
        }
    }
}
public class windowsTest1 {
    public static void main(String[]args){
        Windows1 windows1=new Windows1();

        Thread t1=new Thread(windows1);
        Thread t2=new Thread(windows1);
        Thread t3=new Thread(windows1);

        t1.setName("窗口1");
        t2.setName("窗口2");
        t3.setName("窗口3");

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

 理想状态

 

极端状态

 

 

 4.1、同步代码块处理实现Runnable的线程安全问题

package com.company;

class Windows1 implements Runnable{
    private int ticket=100;
    @Override
    public void run() {
        while(true){
            synchronized (this) { //此时的this:唯一的windows1对象
                if (ticket > 0) {
                    try {
                        Thread.sleep(100);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println(Thread.currentThread().getName() + ":卖票，票号为：" + ticket);
                    ticket--;
                } else {
                    break;
                }
            }
        }
    }
}
public class windowsTest1 {
    public static void main(String[]args){
        Windows1 windows1=new Windows1();

        Thread t1=new Thread(windows1);
        Thread t2=new Thread(windows1);
        Thread t3=new Thread(windows1);

        t1.setName("窗口1");
        t2.setName("窗口2");
        t3.setName("窗口3");

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

 

 

4.2、同步代码块处理继承Thread类的线程安全问题

package com.company;

class Windows2 extends Thread{
    private static int ticket=100;
    private static Object obj=new Object();

    @Override
    public void run(){
        while(true){
            synchronized (Windows2.class) {
                if(ticket>0){
                    try {
                        Thread.sleep(100);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }

                    System.out.println(getName()+":卖票，票号为："+ticket);
                    ticket--;
                } else {
                    break;
                }
            }
        }
    }
}
public class WindowsTest2 {
    public static void main(String[]args){
        Windows2 t1=new Windows2();
        Windows2 t2=new Windows2();
        Windows2 t3=new Windows2();

        t1.setName("窗口1");
        t2.setName("窗口2");
        t3.setName("窗口3");

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

4.3、同步方法处理实现Runnable的线程安全问题

package com.company;
/**
 * 使用同步方法解决实现Runnable接口的线程安全问题
 *
 * 关于同步方法的总结：
 * 1、同步方法仍然涉及到同步监视器，只是不需要我们显示的声明。
 * 2、非静态的同步方法，同步监视器是：this
 *   静态的同步方法，同步监视器是：当前类本身
 */

class Windows3 implements Runnable{
    private int ticket=100;

    @Override
    public void run() {
        while(true){
            show();
        }
    }

    private synchronized void show() { //同步监视器
        if(ticket>0){
            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName() + ":卖票，票号为:"+ticket);
            ticket--;
        }
    }

}
public class windowsTest3{
    public static void main(String[]args){
        Windows3 windows3=new Windows3();

        Thread t1=new Thread(windows3);
        Thread t2=new Thread(windows3);
        Thread t3=new Thread(windows3);

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

4.4、 同步方法处理继承Thread类的继承安全问题

package com.company;

class windows4 extends Thread{
    private static int ticket=100;

    @Override
    public void run(){
        while(true){
            show();
        }
    }

    private static synchronized void show() { //同步监视器Windows4.class
        if(ticket>0){
            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName() + ":卖票，票号为:"+ticket);
            ticket--;
        }
    }
}
public class windowsTest4 {
    public static void main(String[]args){
        windows4 t1=new windows4();
        windows4 t2=new windows4();
        windows4 t3=new windows4();

        t1.setName("窗口1");
        t2.setName("窗口2");
        t3.setName("窗口3");

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

4.5、 线程安全的单例模式之懒汉式

package com.company;

public class BankTest {
}
class Bank{
    private Bank() {

    }

    private static Bank instance =null;
   

//    
    private static Bank getInstance(){
         // 方式一:效率较差
//         synchronized(Bank.class){
//             if(instance == null){
//                 instance = new Bank();
//             }
//             return instance;
//         }
//        方式二:效率较高
        if(instance == null){
            synchronized (Bank.class) {
                if(instance == null){
                    instance=new Bank();
                }
            }
        }
        return instance;
    }
}

 4.6、死锁的问题

　　

　　

　　

　

　　

　

 

标签：JAVA,Thread,class,线程,new,run,public
From： https://www.cnblogs.com/longlyseul/p/16659526.html

相关文章

  • java基础学习：java中的反射
    一、什么是java反射什么是java的反射？说到反射，写这篇文章时，我突然想到了人的”反省“，反省是什么？吾一日三省吾身，一般就是反思自身，今天做了哪些对或错的事情。java的反......
  • java基础第三天
    位运算符:&:按位与->两个数的二进制数位数上都为1,则整个结果(二进制结果)就为1,否则结果为0|:按位或->两个数的二进制数位数上只要有一个对应为1,则整个结果就为1：>>:......
  • Java基本数据类型
    1.八种基本数据类型（位数）1）布尔型boolean（8） 字节型byte（8）  定点类型字符型char（16） ......
  • Java课堂检测反思总结
    在进行课堂检测之前我做完了老师之前发的类似题目，自我感觉还可以，原本以为可以取得一个不错的成绩，但是现实还是给了我当头一棒。15分的课堂检测，最后只得了11.5分，没有达到我......
  • java锁：第一章：公平和非公平锁
    公平和非公平锁是什么？二者区别？ 更多内容请见原文，原文转载自：https://blog.csdn.net/weixin_44519496/article/details/120323099......
  • JAVA进阶--日志框架、阶段项目实战--2022年9月5日
    第一节 日志框架1、什么是日志用来记录程序运行过程中的信息，并且可以进行永久存储  2、输出语句存在哪些问题，日志结束应该具备哪些特点......
  • 51 | JAVA_数据库JDBC_连接池
    JDBC连接池类似的，在执行JDBC的增删改查的操作时，如果每一次操作都来一次打开连接，操作，关闭连接，那么创建和销毁JDBC连接的开销就太大了。为了避免频繁地创建和销毁JDBC连接，我......
  • 53 | JAVA_TCP编程
    TCP编程使用Socket进行网络编程时，本质上就是两个进程之间的网络通信。其中一个进程必须充当服务器端，它会主动监听某个指定的端口，另一个进程必须充当客户端，它必须主动连接......
  • 52 | JAVA_网络编程基础
    网络编程基础ip地址在互联网中，一个IP地址用于唯一标识一个网络接口（NetworkInterface）。一台联入互联网的计算机肯定有一个IP地址，但也可能有多个IP地址。IP地址又......
  • 54 | JAVA_UDP编程
    UDP编程和TCP编程相比，UDP编程就简单得多，因为UDP没有创建连接，数据包也是一次收发一个，所以没有流的概念。在Java中使用UDP编程，仍然需要使用Socket，因为应用程序在使用UDP时......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99