Java线程基础知识

2020-09-03  本文已影响0人  Android_Gleam

1线程的创建方式

1.1直接继承Thread

class MyThread extends Thread {
        @Override
        public void run() {
            super.run();

        }
    }

1.2实现Runble接口

class MyRunble implements Runnable{

        @Override
        public void run() {

        }
    }

1.3实现Callable接口(这种方式严格意义上来说 并不是一种实现方式 本质上是Runnable的实现方式)

class MyCallable extends Callable<String>{

        @Override
        public String call() throws Exception {
            return "返回值";
        }
    }

1.4对应的调用方式

public static void main(String[] args){
        //方式一
        MyThread myThread = new MyThread();
        myThread.start();
        
        //方式二
        new Thread(new MyRunble()).start();
        
        //方式三(FutureTask最终派生自Runnable)
        FutureTask<String> futureTask = new FutureTask<String>(new MyCallable());
        new Thread(futureTask).start();
        futureTask.get();//获取返回值
    }

1.4不同创建方式的区别

采用继承Thread类方式:
   (1)优点:编写简单,如果需要访问当前线程,无需使用Thread.currentThread()方法,直接使用this,即可获得当前线程。
   (2)缺点:因为线程类已经继承了Thread类,所以不能再继承其他的父类。

采用实现Runnable接口方式:
   (1)优点:线程类只是实现了Runable接口,还可以继承其他的类。在这种方式下,可以多个线程共享同一个目标对象,所以非常适合多个相同线程来处理同一份资源的情况,从而可以将CPU代码和数据分开,形成清晰的模型,较好地体现了面向对象的思想。
   (2)缺点:编程稍微复杂,如果需要访问当前线程,必须使用Thread.currentThread()方法。

Runnable和Callable的区别:
   (1)Callable规定的方法是call(),Runnable规定的方法是run().
   (2)Callable的任务执行后可返回值,而Runnable的任务是不能返回值得
   (3)call方法可以抛出异常,run方法不可以,因为run方法本身没有抛出异常,所以自定义的线程类在重写run的时候也无法抛出异常
   (4)运行Callable任务可以拿到一个Future对象,表示异步计算的结果。它提供了检查计算是否完成的方法,以等待计算的完成,并检索计算的结果。通过Future对象可以了解任务执行情况,可取消任务的执行,还可获取执行结果。

start()和run()的区别
start()方法用来,开启线程,但是线程开启后并没有立即执行,他需要获取cpu的执行权才可以执行
run()方法是由jvm创建完本地操作系统级线程后回调的方法,不可以手动调用(否则就是普通方法)

2线程的停止方式

2.1stop()

暴力的停止,会造成危险和问题,不可使用,不详细介绍。

interrupt()

目前最优的办法,目的是为了完成run方法的运行。
调用interrupt()方法分为两种情况,当前线程是否调用了sleep,不同的情况,处理方式不一样。

2.2.1未调用

static class MyThread extends Thread {
        @Override
        public void run() {
            super.run();
            while (!isInterrupted()){
                System.out.println("MyThread run");
            }
        }
    }

public static void main(String[] args) throws ExecutionException, InterruptedException {
        //方式一
        MyThread myThread = new MyThread();
        myThread.start();

        Thread.sleep(2);
        //发射终止信号
        myThread.interrupt();

    }

运行截图:


image.png

这种方式就是改变isInterrupted的值,从而达到退出循环的目的,当然我们可以根据自己的实际情况来加入判断,从而完成run方法的运行,达到停止线程的目的。

isInterrupted是系统提供的,默认值是false所以我们在判断的时候要加上!。当我们调用interrupt()方法后,isInterrupted会被置为true。

2.2.1调用

static class MyThread extends Thread {
        @Override
        public void run() {
            super.run();
            while (!isInterrupted()){
                System.out.println("MyThread run");

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

我们在之前代码的基础上加了sleep方法,这时我们发现,循环不能被停止了(调用代码不变)。


image.png

为什么我们只是让线程睡一觉,就不行了呢?
我们先看下sleep的源码

    public static native void sleep(long millis) throws InterruptedException;

通过源码我们发现,sleep方法会抛出一个InterruptedException异常。

当我们调用interrupt()方法后,如果线程调用sleep方法,那么就会抛出InterruptedException异常,而在抛出异常的时候,会清除中断标记。所以当循环进行下一次循环的时候,还是会满足条件,继续执行。

这里我们要注意的一点是,调用interrupt()方法后,调用sleep方法抛出异常的时候会清除中断标记,而wait不会

要注意的是,如果我们没有调用interrupt()方法,调用sleep()方法的时候,是不会抛出异常的,这点我觉得很重要,因为这点我苦恼了半天,后来自己跑了几遍代码才发现是这么回事。

综上所述,我们得知了调用sleep()方法时会抛出InterruptedException异常,并且会清除中断标记,那么我们就可以在异常捕获阶段进行处理了。

static class MyThread extends Thread {
        @Override
        public void run() {
            super.run();
            while (!isInterrupted()){
                System.out.println("MyThread run");

                try {
                    Thread.sleep(10);
                } catch (InterruptedException e) {
                    //根据自己的需要 再将isInterrupted置为true
                    interrupt();
                    e.printStackTrace();
                    //根据当前代码逻辑 我们可以直接终止循环
                    break;
                }
            }
        }
    }

2.1守护线程

我们也可以通过setDaemon()方法将线程设为守护线程,这样当被守护的线程执行完后,守护线程也就随之而结束了。

 public static void main(String[] args) throws ExecutionException, InterruptedException {
        //方式一
        MyThread myThread = new MyThread();
        myThread.setDaemon(true);
        myThread.start();
        Thread.sleep(1000);
//        //发射终止信号
//        myThread.interrupt();

    }

上面的代码也就是说myThread守护main线程 main线程结束 不管myThread是否结束 myThread都要结束。
(谁调用的myThread,myThread就守护谁,main线程调用的,myThread就守护main线程)

上一篇 下一篇

猜你喜欢

热点阅读