JAVA 多线程实现方式

阳光穿透心脏的1/2处 2021-12-19 23:41 308阅读 0赞

学多线程之前先理解下并发和并行、进程和线程：

并发：是指两个或多个事件在同一**时间段**发生（交替发生）

并行：指两个或多个事件在同一**时刻**发生（同时发生）

进程：一般来说在内存中的程序称为进程

线程：线程输于进程，是进程的一个**执行单元。** 每执行一个功能就开启一条程序到CPU的路径，这条路径称为线程。

--------------------

线程调度：

**分时调度**   
所有线程轮流使用 CPU 的使用权，平均分配每个线程占用 CPU 的时间。   
**抢占式调度**   
优先让优先级高的线程使用 CPU，如果线程的优先级相同，那么会随机选择一个(线程随机性)，Java使用的为抢占式调度。

--------------------

主线程：执行主（main）方法的线程，是一个单线程，从main方法开始

--------------------

**多线程的实现：**

1. 继承Thread类，重写run方法，设置线程任务，创建Thread类的子类对象，调用start方法，当前线程即可与run方法并发运行

执行原理：本来只有一条通往cpu的一条main线程路径，当new一个Thread时，将会开辟一条新路径，当调用start（）方法时   ，则会执行run（）方法。

因为调用start（）方法，run方法会在不同的栈中执行，所以多线程之间互不影响。

2. 实现Runnable接口  ，重写run方法，创建一个 接口实现类对象，再创建一个Thread类对象，并将接口实现类对象作为参数传递进去，再调用start（）方法。

RunnableTest r = new RunnableTest（）；  Thread t = new Thread（r）;    t.start( );

--------------------

**获取线程的名称 **

1.使用Thread类中的getName（）方法

String  getName() 获取线程的名称  String name = getName();

2. 可以先获取当前执行的线程，使用线程的getName（）方法获取线程的名称

static Thread currentThread（）返回当前正在执行的线程对象的引用

Thread t = Thread.currentThread（）；

String name  = t.getName()

**设置线程的名称 **

1 使用setName设置线程名称   MyThread t  =  New MyThread（）； t.setName("名称");

2.重载一个带参构造方法，方法体内调用父类构造方法   public MyThread（String name） \{  super（name）；\}

--------------------

休眠：使只在执行的线程暂停多少毫秒  public static void sleep（long millis）    因为是个静态方法 直接用类名调用即可

Thread.sleep(1000); 休眠1秒中

--------------------

**实现Runnable 和 继承Thread的区别：**

继承Thread类有一定的局限性，当一个类继承了Thread类就不能在继承其他的类，而实现Runnable接口还可以继承其他类

增强了程序的可扩展性，降低了程序间的耦合

--------------------

通过匿名内部类来实现多线程（可通过Thread类或Runnable接口）

public class Demo {
        public static void main(String[] args) {
            // 继承Thread类实现多线程
            new Thread() {
                public void run() {
                    for (int i = 0; i < 100; i++) {
                        System.out.println(Thread.currentThread().getName() + "--" + i);
                    }
                }
            }.start();
            // 实现Runnable接口实现多线程
            new Thread(new Runnable() {
    
                public void run() {
                    for (int i = 0; i < 100; i++) {
                        System.out.println(Thread.currentThread().getName() + "--" + i);
                    }
                }
            }) {
            }.start();
        }
    }

--------------------

最后来两个测试小程序：

//继承Thread类
    import java.lang.Thread;
    public class Thread1 extends Thread {
    
        public void run(){
    
            for(int i=1;i<20;i++){
                System.out.println("当前Thread值为"+i);
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }

//实现Runnable接口
    public class Runnable1 implements Runnable {
        @Override
        public void run() {
            for(int i=1;i<20;i++){
                System.out.println("当前Runnable值为"+i);
            }
    
        }
    }

public class Demo{
    
        public static void main(String[] args) throws InterruptedException {
    
            
            Runnable1 r1 = new Runnable1();
            Thread tr = new Thread(r1);
            tr.start();
    
    
    
            Thread1 t1 = new Thread1();
            t1.start();
    
          //测试主线程
                for(int i=1;i<20;i++) {
                System.out.println("当前main值为" + i);
            }
    
    
    
    
        }
    
    }