美文网首页Handler程序员Android开发
Android多线程之线程间通信

Android多线程之线程间通信

作者: JingChen_ | 来源:发表于2021-01-10 18:11 被阅读0次

线程通信

多个线程在处理同一个资源,并且任务不同时,需要线程通信来帮助解决线程之间对同一个变量的使用或操作。就是多个线程在操作同一份数据时, 避免对同一共享变量的争夺。比如在两个并发的线程,线程A需要等线程B执行完得到的结果后,线程A才能拿这结果执行自己的任务,那么假如没有通信的话,两个并发的线程,我们就不能保证线程A能正确的执行任务,因为我们不能保证线程B一定是在线程A之前执行完(并发情况下)。所以我们要引入线程通信。

停止一个线程(stop、interrupt)

假如一个线程让另一个线程停止执行,那么有一个方法stop()方法,但是!这个方法被弃用了,因为很危险,不要去用它。为什么说很危险,想想看,当我们把一个运行中的线程运行到一半把它切掉,那么线程中的数据就不完整了,可能会导致后面一系列操作的数据都是错误的。不要想着去考虑合适的位置保证运行完了再去stop(),因为我们程序在任何地方都有可能中断,这种机制就不靠谱。

所以不要用stop()去停止一个线程,有这功能但不要去用,所以面试官问你如何正确的停止一个线程,别再答stop()了!

那么不要用的话该用什么呢?Thread还提供了一个方法interrupt(),用来打断线程。打断和停止不是同个意思,打断是把线程标记为中断状态,标记,提醒这个线程要可以停止了,但是呢,他没有终止的功能,只是个提醒的标记。线程中可以用isInterrupted()来对代码块判断,例如循环遍历输出,我们可以在for里面加一层if判断isInterrupted()的返回值,true表示为打断,所以当为true时,我们可以在里面做一些停止前的操作,这些操作是为了停下来的操作不会影响到后续操作,至于怎么设定要看自己的需求,然后操作完直接break或者return退出。这样,什么时候停止的我们都可以知道了。

interrupt只是个标志,提醒的效果,至于线程收到提醒后,怎么停止或者要不要停止,要按自己的需求来实现。

注:Thread.interrupted(),效果是跟isInterrupted()类似,但isInterrupted()不会改变自身的值也就是恒定为true,也就是中断提醒的效果,Thread.interrupted()得到要中断的消息后,执行完会把自身的值设为false,也就是只能提醒一次。

interrupt()还有一个功能,就是叫醒sleep()中的线程并且可以停止该线程,那刚才说的interrupt()不是需要线程配合才能停止吗?想想看,sleep()中的线程会对数据吗?我们不想用stop就是因为不知道数据别变成什么样了,那休眠中的线程不改数据,所以可以直接停止,那么又有个问题,停止的话对数据做退出前的操作应该在哪呢?还记得在Java中使用Thread.sleep()时候必须使用try-catch吧(Kotlin去除必写try-catch,需要手动加上),catch中是InterruptedException。在我们的理解中,catch是异常,但还有一种就是特殊情况下的操作,对特殊情况进行处理,不一定指的是异常,所以这里的InterruptedException是对特殊情况下的操作,那么catch里面应该写什么呢?想下之前说的线程收到中断消息该怎么做呢?所以一样的,catch中的操作就是一些停止前的操作。但是在InterruptedException要return,如果不return后面就没有退出的操作了,因为和Thread.interrupted()一样,只能打断一次。

interrupt可以叫醒一个sleep中的线程,怎么叫醒呢?直接走InterruptedException。

等待和唤醒(wait、notify/notifyAll)

来看下两个方法

    private var test = ""
    @Synchronized
    private fun initString() {
        test = "123"
    }
    @Synchronized
    private fun getString() {
        println(test)
    }

(关于Synchronized关键字在一篇文章里面有写到)
一个是初始化test,一个是打印test的值,那么现在分别在两个线程执行这两个方法,要求能成功打印出test初始化的值。

    private val thread1 = Thread {
        initString()
    }
    private val thread2 = Thread {
        getString()
    }

首先我们知道打印出来的结果肯定会有不合要求的(有锁的存在),那么就是要等thread1执行完后才执行thread2,所以引进了wait()方法。(这个wait()是在Object里面的,不是线程中的)

wait()是可以在让线程释放锁,进入等待状态,但是等待的地方不是和竞争同个锁的线程是同个地方,而是进入等待对列中,只有从等待队列中出来的才有资格跟其他线程竞争。那么怎么才能唤醒线程的wait()呢?notify可以让等待中其中一个的线程从等待队列中出来。那么就应该这么写

    @Synchronized
    private fun getString() {
        while (test == "") {
            wait()
        }
        println(test)
    }
    @Synchronized
    private fun initString() {
        test = "123"
        notifyAll()
    }

当线程2先得到锁执行getString时,会释放锁进入等待状态,这时线程1执行initString,给test赋值并且notify等待中的线程,之后线程2就被唤醒,这时候再去打印test。

注:notify和notifyAll都是唤醒线程,但是notify只能唤醒等待中其中一个的线程,而notifyAll唤醒全部等待中的线程,至于哪个被唤醒后能再去调用,就要看哪个跳过了wait方法,就像getString中的while条件。

join、yield

join就比较好解释了,看代码

    private val join1 = "join1"
    private val join2 = "join2"

    private val thread1 = Thread{
        Thread.sleep(1000)
        println(join1)
    }
    private val thread2 =Thread{
        thread1.join()
        println(join2)
    }

假如现在先调thread2.start()再调thread1.start(),如果不加thread1.join(),那么肯定输出join2,再输出join1。加了join的话,现在就被插入,然后当前线程停止,执行该调用join的线程。

其实就是把两个并行的线程变成两个先后的顺序

yield

就是把自己线程的时间片暂时让出一下,让出的给谁?让出给通优先级竞争的线程,他们先执行

相关文章

  • 多线程通信简介

    这里是对学习的多线程通信做个记录.之前也对多线程安全 以及 Android 中多线程通信进行了接受,可以前往查看...

  • Java多线程:synchronized的可重入性

    从Java多线程:线程间通信之volatile与sychronized这篇文章中我们了解了synchronized...

  • Android多线程之线程间通信

    线程通信 多个线程在处理同一个资源,并且任务不同时,需要线程通信来帮助解决线程之间对同一个变量的使用或操作。就是多...

  • Java多线程(2)

    Java多线程(2) 线程间的通信 线程间的通信又称为进程内通信,多个线程实现互斥访问共享资源时会互相发送信号或等...

  • GCD练习

    GCD练习 ios 多线程 GCD : ios 多线程 全剧队列,异步执行 线程间通信 信号量 文件锁 单利模式 ...

  • JUC中线程之间得通信

    使用synchronized实现线程间通信,线程间通信:1、生产者+消费者2、通知等待唤醒机制.多线程编程模板:1...

  • Java基础知识02- 线程

    多线程通信 :什么是多线程通信 ?怎么进行通信 ? 多线程通信就是多个线程同时操作同一个全局变量,但是操作的动作不...

  • Android线程间通信原理以及多线程

    概述 本文要介绍的内容主要分为如下几块 线程间通信常用的方法 Handler原理解析 常用的线程池介绍 Andro...

  • 线程间通信及android多线程解析

    Synchroized的使用 使用synchroized关键字有两种方式第一种: 当线程访问方法A,由于是sync...

  • 线程间通信原理及Android多线程

    线程间交互 一个线程启动别的线程:new Thread().start()、Executor.execute() ...

网友评论

    本文标题:Android多线程之线程间通信

    本文链接:https://www.haomeiwen.com/subject/gvbcaktx.html