多线程之间的通信(等待唤醒机制、Lock 及其它线程的方法)

一、多线程之间的通信。

    就是多个线程在操作同一份数据, 但是操作的方法不同。

    如: 对于同一个存储块,其中有两个存储位:name   sex, 现有两个线程,一个向其中存放数据,一个打印其中的数据。

    为了解决上述问题中的安全问题(在存放线程进行存放操作的时候, 打印线程不能对共有数据进行操作),所以应当对两个线程
       操作共有数据的代码部分进行同步(使用synchronized(),来进行同步, 注意 :使用同一个对象作为同步锁。

二、等待唤醒机制。

    在上述案例实现过后运行,会发现:打印结果顺序并不是按照存放顺序进行的, 所以在此处就引入了等待唤醒机制。

        解释:就是在一个线程进行了规定操作后,就进入等待状态(wait()), 等待其他线程执行完他们的指定代码过后 再将其唤醒(notify())。
         在有多个线程进行等待时, 如果需要,可以使用 notifyAll()来唤醒所有的等待线程。

    所使用的方法(关键字):
          对象名.wait(); 在其他线程调用此对象的 notify() 方法或 notifyAll() 方法前,导致当前线程等待。
          对象名.notify(); 唤醒在此对象监视器上等待的单个线程。
          对象名.notifyAll();唤醒在此对象监视器上等待的所有线程。


    
        注意:以上方法(关键字),都必须使用在同步中,因为其需要对持有该对象监视器所有权(锁)的线程进行操作。
      所以必须使用在同步中,因为只有同步中的线程才具有该对象监视器的所有权(锁),

        wait()和sleep()一样,都会抛出 InterruptedException 异常。

        而且,以上方法都定义在类:Object中

            是因为,这些方法在操作同步中的线程的时候,都必须标示其所操作线程所持有的锁(被该锁的对象调用),
          而只有同一个对象监视器下(同一个锁上的)的被等待线程,可以被持有该锁的线程唤醒,(无法唤醒不同锁上的线程)
            即: 等待和唤醒的必须是同一个对象的监视器下(同一个锁上)的线程。
          而锁可以是任意已近确定的对象, 能被任意对象调用的方法应当定义在 Object类中。


      监视器(锁): 同一个对象的监视器下(同一个锁上)的线程,一次只能执行一个:就是拥有监视器所有权(持有锁)的那一个线程。


三、接口Lock和 接口Condition

    注:在使用Lock 与Condition 时,必须引入其工具包:import java.util.concurrent.locks.*

             在jdk1.5以上,为了解决多个线程同时在对一份共享数据进行不同操作时出现的安全问题(要么陷入所有线程同时等待的状态、

          要么每次唤醒所有等待线程的问题),
              其为我们提供了新的 锁工具: Lock来替换 synchronized , 由 Lock对象所创建的绑定于该Lock对象的 condition对象

            替换了object类中的wait,notify操作。


    1、Lock接口, 已知实现该接口的类: ReentrantLock, ReentrantReadWriteLock.ReadLock, ReentrantReadWriteLock.WriteLock

      1)、 ReentrantLock(大体功能与 synchronized相当,不过可以绑定多个condition)


            构造方法:ReentrantLock() 创建一个 ReentrantLock 的实例。
                 ReentrantLock(boolean fair) 创建一个具有给定公平策略的 ReentrantLock

            常用方法: void lock() :获取一个锁。
                  void unlock() :释放该锁。
                  Condition newCondition() 返回用来与此 Lock 实例一起使用的 Condition 实例。




    2、Contition接口, 已知实现类:AbstractQueuedLongSynchronizer.ConditionObject, AbstractQueuedSynchronizer.ConditionObject(暂时不学习)

            常用方法:void await() 造成当前线程在接到信号或被中断之前一直处于等待状态。
                 void signal() 唤醒一个等待线程。
                 void signalAll() 唤醒所有等待线程。


        常见代码示例:
          class BoundedBuffer {
            final Lock lock = new ReentrantLock(); //创建一个Lock的子类对象 lock
            final Condition notFull = lock.newCondition(); //调用lock的newCondition方法,创建一个condition子类对象 notFull
            final Condition notEmpty = lock.newCondition(); //调用lock的newCondition方法,创建一个condition子类对象 notEmpty

            public void put(Object x) throws InterruptedException { //
                lock.lock(); //获取锁
                try {
                    while (判断语句)
                      notFull.await(); //判断成功,线程等待于notFull下。

                    操作代码

                    notEmpty.signal(); //唤醒notEmpty下的等待线程。
                } finally { //保证其后语句执行。
                     lock.unlock(); //释放锁。
                }
            }

            public Object take() throws InterruptedException {
                lock.lock();
                try {
                  while ()
                    notEmpty.await();
                  操作代码
                  notFull.signal();

                } finally {
                      lock.unlock();
                }
            }
          }



四、停止线程

      注:在旧版本的jdk中存在stop方法,但是在新版本中。此方法被过时。

      线程停止的原理: 当 run方法中的代码执行完毕过后,就自动停止该线程。

          1、当线程中是循环代码的时候, 只要控制住循环结束,就能够结束该线程。

              特殊情况:当线程中有wait()语句或者await()等语句时,会使得线程处于冻结状态, 让控制循环结束的代码或者标记无法执行或读取,

            那么线程就不会结束。

              当所有线程都陷入冻结,没有指定方法解除冻结时,就需要我们强制清除冻结状态,这样就可以操作标记使循环结束。

              Thread类中提供了这一方法: Interrupt()方法,(等待型语句本身会有一个InterrptedException异常的判断,

                      只要被Interrupt方法打断冻结,就会抛出这一异常, 我们就可以在异常处理语句中建立循环结束的标记)。



五、守护线程

    Thread类中有一个方法,调用该方法并传入 true ,能将该线程定义为 守护线程(后台线程),
        该方法是: void setDaemon(boolean on) 将该线程标记为守护线程或用户线程。(调用时应当传入true)。

      注意: 1、将该线程标记为守护线程或用户线程。当正在运行的线程都是守护线程时,Java 虚拟机退出。
        (就是说,后台线程依赖于前台线程)

          2、该方法必须在启动线程前调用。

        示例: Thread t = new Thread();
            t.setDaemon(true);
            t.start();
          此时的线程 t 为守护线程。


六、Join方法。

    vpi解释:void join() 等待该线程终止。

    在线程A执行的时候,碰到了B线程.join方法时,A线程就会等待,等B线程执行完,才继续执行。
    (当在调用join方法时传入参数: long millis 时,表示 A线程等待B线程执行时间最长为millis毫秒。)

      join可以用来临时加入线程执行。

转载于:https://www.cnblogs.com/soficircle/p/6649272.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/393329.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Linux iptables 配置详解

一、配置一个filter表的防火墙 1. 查看本机关于 iptables 的设置情况 # iptables -L -n Chain INPUT (policy ACCEPT) target prot opt source destination Chain FORWARD (policy ACCEPT) target prot opt source destination Chain OUTPUT (policy ACCEPT) …

06 Nginx

1.检查linux上是否通过yum安装了nginx rpm -qi nginx2.解决安装nginx所依赖包 yum install gcc patch libffi-devel python-devel zlib-devel bzip2-devel openssl-devel ncurses-devel sqlite-devel readline-devel tk-devel gdbm-devel db4-devel libpcap-devel xz-devel ope…

java编写安卓程序代码,安卓:从Android的Java源代码code创建UML

i am looking for a program that can create automatically an Uml from my Java-Android source code.I have tested ArgoUml, but it does not support Android.Have any one a suggestion?Thanks!解决方案I can second what Tom Morris wrote in the comment above. Even …

leetcode1052. 爱生气的书店老板(滑动窗口)

今天,书店老板有一家店打算试营业 customers.length 分钟。每分钟都有一些顾客(customers[i])会进入书店,所有这些顾客都会在那一分钟结束后离开。 在某些时候,书店老板会生气。 如果书店老板在第 i 分钟生气&#xf…

amazon alexa_在Amazon Alexa上推出freeCodeCamp编码琐事测验

amazon alexaNow you can learn coding concepts hands-free using an Amazon Echo.现在,您可以使用Amazon Echo免提学习编码概念。 freeCodeCamp.org contributor David Jolliffe created a quiz game with questions on JavaScript, CSS, networking, and comput…

第一类第二类丢失更新

第一类丢失更新 A事务撤销时,把已经提交的B事务的更新数据覆盖了。这种错误可能造成很严重的问题,通过下面的账户取款转账就可以看出来: 时间 取款事务A 转账事务B T1 开始事务 T2 开始事务 T3 查询账户余额为1000元 …

oracle数据字典表与视图

oracle数据字典表与视图 数据字典是数据的数据,也就是元数据。描述了数据库的物理与逻辑存储与相应的信息。模式中对象的定义信息,安全信息,完整性约束信息,和部分的性能监控信息等。数据字典表 与视图存储在system表空间中的。有…

团队作业——项目Alpha版本发布

---恢复内容开始--- https://edu.cnblogs.com/campus/xnsy/SoftwareEngineeringClass1 https://edu.cnblogs.com/campus/xnsy/SoftwareEngineeringClass1/homework/3329 <作业要求的链接> Gorious Computer <写上团队名称> 发布项目α版本&#xff0c;对项目…

java脏字过滤_脏字过滤

1.[文件]SensitiveWordFilter.java ~ 7KB下载(141)package com.forgov.sharpc.infrastruture.util;import static java.util.Collections.sort;import java.util.ArrayList;import java.util.Collection;import java.util.Comparator;import java.util.HashSet;import java.uti…

react中使用构建缓存_完整的React课程:如何使用React构建聊天室应用

react中使用构建缓存In this video course, youll learn React by building a chat room app.在本视频课程中&#xff0c;您将通过构建聊天室应用程序来学习React。 By the end of the video, youll have a solid understanding of React.js and have your very own chat room…

leetcode1509. 三次操作后最大值与最小值的最小差

给你一个数组 nums &#xff0c;每次操作你可以选择 nums 中的任意一个元素并将它改成任意值。 请你返回三次操作后&#xff0c; nums 中最大值与最小值的差的最小值。 示例 1&#xff1a; 输入&#xff1a;nums [5,3,2,4] 输出&#xff1a;0 解释&#xff1a;将数组 [5,3,…

MySQL异步复制

准备&#xff1a;主备库版本一致&#xff0c;正常安装软件。 1、主库上设置一个复制使用的账户&#xff1a; mysql> grant replication slave on *.* to rep1192.168.100.136 identified by dbking; Query OK, 0 rows affected (0.18 sec) mysql> select user,host,passw…

开源一个爬取redmine数据的测试报告系统

背景 软件测试的最后有一道比较繁琐的工作&#xff0c;就是编写测试报告。手写测试报告在数据统计和分析上面要耗费比较大的事件和精力。之前工作室使用mantis管理bug缺陷。公司有内部有个系统&#xff0c;可以直接从mantis上面获取数据并进行统计&#xff0c;生成一份测试报告…

java cxf 双向通讯_CXF 在spring boot 2 发布多个服务

0. 问题来源之前配置cxf服务端都是在spring 3以下&#xff0c;后来使用spring mvc 还都是基于xml的配置文件模式&#xff0c;在springboot模式下&#xff0c;实现起来更为简单了。此次记录下spring boot 2下的实现方式。1. 准备工作项目中&#xff0c;直接拉入spring boot cxf相…

小程序 坚屏_如何构建坚如磐石的应用程序

小程序 坚屏不同的应用程序设计选项概述 (An overview of different app design options) When we design software, we constantly think about error cases. Errors have a huge impact on the way we design and architecture a solution. So much so, in fact, that there …

C# 分层

三层架构分为&#xff1a;表现层&#xff08;UI&#xff09;、业务逻辑层&#xff08;BLL&#xff09;、数据访问层&#xff08;DAL&#xff09;再加上实体类库&#xff08;Model&#xff09; 转载请注明出自朱朱家园http://blog.csdn.net/zhgl7688 1、实体类库&#xff08;Mod…

leetcode1177. 构建回文串检测(前缀和)

给你一个字符串 s&#xff0c;请你对 s 的子串进行检测。 每次检测&#xff0c;待检子串都可以表示为 queries[i] [left, right, k]。我们可以 重新排列 子串 s[left], …, s[right]&#xff0c;并从中选择 最多 k 项替换成任何小写英文字母。 如果在上述检测过程中&#xf…

java界面化二叉排序树_层次序创建二叉树(图形界面和控制台输入实现)

1 2018.11.72 XT34 /**5 * 功能&#xff1a;构造二叉树6 * 说明&#xff1a;7 * 1.主函数输入模式有两种&#xff0c;BT参数 true 图形界面&#xff0c;false 控制台输入8 * 2.构造树是按层次遍历结果输入的 如&#xff1a;ABCDE*F**GH9 */1011 import javax.swing.*;12 import…

web开发环境_Web开发人员的开发环境

web开发环境With all the tools and programs available, it can be challenging to figure out the best way to set up your development environment on your computer.使用所有可用的工具和程序&#xff0c;寻找在计算机上设置开发环境的最佳方法可能是一项挑战。 In this…

使用.net Stopwatch class 来分析你的代码

当我们在调试&#xff0c;优化我们的代码的时候&#xff0c;想知道某段代码的真正的执行时间&#xff0c;或者我们怀疑某段代码&#xff0c;或是某几段代码执行比较慢&#xff0c; 需要得到具体的某段代码的具体执行时间的时候。有一个很好用的类Stopwatch。 Stopwatch 类在 Sy…