这一块主要是讨论关于进程同步的相关问题,主要是考虑一下的关键字:锁对象、条件对象 -> synchronized wait() notify()。

1、关于锁对象与条件对象:

所对象的定义在java中的java.util.concurrent.locks中Lock接口,具体可以有多种实现。对于lock()方法而言,通常的使用方法如下:

比如自己写的某个类已经实现了Lock接口,并且生成了一个实例myLock。之后用Lock接口的lock()方法来控制临界区的代码:

myLock.lock()//相当于获取了这个锁,如果锁同时被另一个线程拥有,则会发生阻塞
try
{//临界区的代码
}finally
{myLock.unlock()//放弃对这个锁的拥有权
}

这个用法感觉上就像是之前操作系统中的阻塞原语的用法一样,用P、V互斥信号量,把临界区的代码包在里面。

条件对象,这个条件对象的使用就像是之前PV操作中的同步原语一样,condition对象的声明方法也在java.util.concurrent.locks 接口中。使用newCondition()可以返回一个condition实例。

调用conditioninstance.await()方法之后,则当前线程会被阻塞,并且放弃了当前线程对锁的拥有权。

conditioninstance.signalAll()这个方法的调用会激活因为这一条件而等待的所有的线程,这些线程会从等待集中移除,变成再次可运行的。

通常与Lock结合起来使用:

myLock.Lock()try{While(某一个条件不满足的时候)conditioninstance.await();//某一个条件符合之后 就会往下实行

…//相关的操作执行完成后 唤醒等待的线程 这些被唤醒的线程通过竞争实现访问

conditioninstance.await();}finally{myLock.unlock();}

2、synchronized 关键字以及 notify wait 的使用:

基本上来说,这个与上面的lock以及条件对象,所实现的功能是相同的。

比如说一个用synchronized关键字修饰的方法:

public synchronized void method()
{Method body
}

这样的效果与使用 lock类似,相当于拥有了调用这个方法的一个对象的内部锁

public void method()
{
this.intrinsicLock.lock();
try
{Method body
}
finally
{
   this.intrinsicLock.unlock();
}
}

2.1、对于synchornized关键字的说明:

由于在多线程的环境中,可能会有两个或者更多的线程试图同时访问某一个资源,为了保证对于资源修改的有效性,以及修改不会引起冲突,必须采用一定的机制来控制线程对于某个资源的访问的权限。可以通过对临界代码加锁的方式来进行限制,即是前面提到的,采用锁对象的方式来进行限制。

每一个对象内置的都有一个锁或者是被称作monitor。被synchronized关键字修饰的方法叫做同步方法。当某个类的实例去访问这个实例的同步方法的时候,则被synchronized关键字修饰的方法相当于被对象的内部锁给包住了,通过synchronized关键字给这个方法上了锁,这个锁是这个对象本身的内置的锁,此时其他的任何一个线程都无法通过这个对象来直接访问这个方法,必须要等这个方法执行完后,将这个对象的内部的锁的拥有权释放,之后其他线程才能再通过这个对象来获执行synchronized方法。这样比起直接生成锁对象,再在最后解锁的方式要精简一些。

注意synchronized关键字要放在方法返回类型之前。

具体例子的代码:

package com.javase.thread;//这个主要是演示一下 synchornized方法public class threadTest3 {public static void main(String []args){synExample synexmple=new synExample();Thread t1=new theThread(synexmple);Thread t2=new theThread(synexmple);t1.start();t2.start();}}class synExample{public synchronized void excute() throws InterruptedException{for(int i=0;i<10;i++){System.out.println("the number is "+ i);}return;}}class theThread extends Thread{//注意这里要通过 synExample对象来调用excute方法private synExample synexample;public theThread(synExample syn){this.synexample=syn;}public void run(){try {this.synexample.excute();} catch (InterruptedException e) {// TODO Auto-generated catch block

e.printStackTrace();}return;}}

这个加上了 synchronized 关键字之后,两个线程就会交替地执行 synExample 实例的excute方法,先出0-9,再出0-9。要是不加synrchonized关键字的话,就实现不了互斥访问excute关键字的效果,可能就是乱序输出。

特别注意一下,当Synchronized关键字修饰的是一个static方法的时候,此时通过synchronized关键字激活的是Class类对象的锁,并不是通过Class类生成的实例的锁。这样的话,任何相关线程通过这个class类对象来访问任何static synchornized方法(访问同一个类的static synchornized方法),都是可以实现互斥访问的。

2.2、关于synchornized块:

通过synchornized关键字来修饰一个方法,这样实现的一个互斥访问可能是粗粒度的,比如一个方法中只有某一部分需要同步,这样的话就需要用到synchrornized块来控制,表示对于块中的代码而言,某时刻只要有一个线程在执行就好。采用synchronized块的时候通常要设置一个私有的Object对象,这个Object对象没有什么实际的意义,只是用来提供一个可以使用的内部锁。

参考下面的例子:

package com.javase.synchronizedblock;public class blockTest {//这个主要是测试一下 关于synchornized块的信息public static void main(String[]args){//两个线程要访问同一个example类对象

Example example=new Example();Thread t1=new threadExample1(example);Thread t2=new threadExample1(example);t1.start();t2.start();}}class Example{private Object obj=new Object();public void excute(){int i;for(i=1;i<=10;i++){System.out.println("the number is "+i);}synchronized(obj){for(i=11;i<=20;i++){try {Thread.sleep(100);} catch (InterruptedException e) {// TODO Auto-generated catch block

e.printStackTrace();}System.out.println("the number of synchronized block in excute is "+i);}}}}class threadExample1 extends Thread{private Example example;//构造函数public threadExample1(Example example){this.example=example;}public void run(){example.excute();}}执行结果:
/*
the number is 1
the number is 2
the number is 1
the number is 3
the number is 2
the number is 4
the number is 3
the number is 5
the number is 4
the number is 6
the number is 5
the number is 7
the number is 6
the number is 8
the number is 7
the number is 9
the number is 8
the number is 10
the number is 9
the number is 10
the number of synchronized block in excute is 11
the number of synchronized block in excute is 12
the number of synchronized block in excute is 13
the number of synchronized block in excute is 14
the number of synchronized block in excute is 15
the number of synchronized block in excute is 16
the number of synchronized block in excute is 17
the number of synchronized block in excute is 18
the number of synchronized block in excute is 19
the number of synchronized block in excute is 20
the number of synchronized block in excute is 11
the number of synchronized block in excute is 12
the number of synchronized block in excute is 13
the number of synchronized block in excute is 14
the number of synchronized block in excute is 15
the number of synchronized block in excute is 16
the number of synchronized block in excute is 17
the number of synchronized block in excute is 18
the number of synchronized block in excute is 19
the number of synchronized block in excute is 20
*/

可以看出来,生成两个线程实例来访问通样一个Example对象,这个Example对象输出的1-10的部分没有加锁,11-20的部分被放在了synchronized块中,结果很显然,synchronized块中的部分实现了互斥访问,而外面的部分没有互斥访问,输出的顺序是混乱的。

注意synchornized块的调用方式:

直接 synchronized(obj) { 临界代码块 } 这样就ok 了。

2.3、关于wait与notify方法

wait与notify都是Object类中的方法,重要性显而易见,它们所实现的功能与之前的条件对象的功能是一致的。无论是wait与notify全需要在synchronized所修饰的方法或者方法块中进行调用,wait()方法与notify()方法总是成对出现的。

调用一个对象的wait方法的时候,该线程释放了对该对象的内部锁的拥有权,直到其他线程调用同一个对象的notify方法,原先的进程的wait状态就解除了等待,有重新竞争获得锁的资格了。注意wait方法与sleep方法的区别,虽然都是线程的等待状态,但是在sleep的时候,线程不会释放掉对锁的拥有权。

notify方法可以唤醒多个线程中的一个,这种唤醒是武断的随机选择的,每次只能唤醒一个,而notifyall方法是解除所有的在该对象上调用wait方法的线程的等待状态,使得所有的被唤醒的进程进入争夺锁的状态中,但最后只有一个线程可以重新获得锁, 一般就用notifyall因为notify有时候使用不当可能会发生死锁。

基本的线程的状态之间的转化关系可以参考下面的这个图:

一个利用notify 与 wait实现的银行账户存取钱的例子:

package com.javase.thread.waitnotify;public class bankTest {public static void main(String[]args){//生成一个账户对象

bankAccount account=new bankAccount();int i;//启动三个取钱的线程for(i=1;i<3;i++){Thread e=new threadExtract(account,i);e.start();}//启动三个存钱的线程for(i=2;i<5;i++){Thread s=new threadSave(account,i); s.start();}}}class bankAccount{private int money=0;//取钱public synchronized void extract(int number) throws InterruptedException{//要是账户钱不够的话 就不能取 要一直等待 存钱之后 才能再取while(money<=number){wait();}//当符合取钱的条件时this.money-=number;System.out.println("取钱:"+number+" 当前账户的余额:"+money);}//存钱public synchronized void save(int number) throws InterruptedException{//加入默认条件下 存钱没有上限 不管余额多少 都能存入this.money+=number;System.out.println("存钱:"+number+" 当前账户的余额:"+money);//存入之后 唤醒 取钱的进程

notifyAll();}}class threadSave extends Thread{private bankAccount account;private int money;public threadSave(bankAccount accon,int savemoney){account=accon;money=savemoney;}public void run(){try {this.account.save(money);} catch (InterruptedException e) {// TODO Auto-generated catch block

e.printStackTrace();}}}class threadExtract extends Thread{private bankAccount account;private int money;public threadExtract(bankAccount accon,int extractmoney){account=accon;money=extractmoney;}public void run(){try {this.account.extract(money);} catch (InterruptedException e) {// TODO Auto-generated catch block

e.printStackTrace();}}}/*运行结果:
存钱:2 当前账户的余额:2
取钱:1 当前账户的余额:1
存钱:4 当前账户的余额:5
存钱:3 当前账户的余额:8
取钱:2 当前账户的余额:6
*/

这个例子主要就是在一个bank类里分别设置了存钱和取钱的方法,很重要的一点是在wait条件判断的那一部分要使用while而不能使用if 因为在线程很多的情况下,采用if往往会出问题,特别是在多个线程的时候,因为在这个线程wait的时候,其他线程可能已经对环境做了一些改变,这个时候还需要对条件进行重新检验。

虽然这个程序里线程的启动顺序是先取钱再存钱,但是并没有出现负数的情况,实际上是取钱进程在等待存钱进程执行完成后,才进行取钱操作。第一个打印出来的肯定是存钱,但是后面几个线程执行顺序就不确定了,每次运行的结果可能都不一样,但是可以保证的是,取钱的数目要小于账户的余额。

转载于:https://www.cnblogs.com/Goden/p/3841739.html

Java thread(4)相关推荐

  1. (转)性能分析之-- JAVA Thread Dump 分析综述

    原文链接:http://blog.csdn.net/rachel_luo/article/details/8920596 最近在做性能测试,需要对线程堆栈进行分析,在网上收集了一些资料,学习完后,将相 ...

  2. 三个实例演示 Java Thread Dump 日志分析

    jstack Dump 日志文件中的线程状态 dump 文件里,值得关注的线程状态有: 死锁,Deadlock(重点关注) 执行中,Runnable 等待资源,Waiting on condition ...

  3. 各种 Java Thread State 第一分析法则

    用 TDA 工具,看到大量 Java Thread State 的第一反应是: 1,线程状态为"waiting for monitor entry": 意味着它 在等待进入一个临界 ...

  4. java Thread sleep 和obj.wait,以及sychronized,minor源码

    sleep()方法是Thread类里面的,主要的意义就是让当前线程停止执行,让出cpu给其他的线程,但是不会释放对象锁资源以及监控的状态,当指定的时间到了之后又会自动恢复运行状态. wait()方法是 ...

  5. linux非守护线程一直不释放,Linux pthread 和 java thread 的是 / 非守护线程的行为

    Linux pthread 和 java thread 的是 / 非守护线程的行为 pthread_xxx 的函数并没有直接提供设置一个 pthread 为守护线程的 API 而 pthread_at ...

  6. java thread join()_Java Thread join() 的用法

    Java Thread中, join() 方法是让调用该方法的主线程执行run()时暂时卡住,等run()执行完成后, 主线程再调用执行join()后面的代码.示例: class ThreadTest ...

  7. Java Thread

    Java Thread 使用Java多线程编程很容易. Java线程总是实现接口java.lang.Runnable, 一般有两种方法: 创建一个类实现接口Runnable, 创造该类的实例作为参数传 ...

  8. java thread join()_Java中Thread.join()的使用方法

    概要 本文分三个部分对thread.join()进行分析: 1. join() 的示例和作用 2. join() 源码分析 3. 对网上其他分析 join() 的文章提出疑问 1. join() 的示 ...

  9. Jvm处理Java Thread 的run方法中抛出异常的流程

    Jvm处理Java Thread 的run方法中抛出异常的流程 参考文章: (1)Jvm处理Java Thread 的run方法中抛出异常的流程 (2)https://www.cnblogs.com/ ...

  10. java thread yield()_Java Thread yield()方法

    Java Thread yield()方法 java.lang.Thread.yield() 方法使当前执行的线程对象来暂停并允许其他线程执行. 1 语法 public static void yie ...

最新文章

  1. 高效搭建Storm全然分布式集群
  2. 华为ws851虚拟服务器,荣耀路由Pro无线中继设置 华为WS851桥接设置教程-192路由网...
  3. linux设备驱动模型 - device/bus/driver
  4. DS博客作业06--图
  5. jQuery心得5--jQuery深入了解串讲1
  6. windows核心编程学习笔记(八)结构化异常处理(Structured Exception Handling)
  7. c语言怎么设计程序框图,C语言课程设计————写下流程图! 谢谢
  8. Intellij IDEA--导入导出配置
  9. 服务器装win10性能怎样,Win10 藏着不给人看的卓越性能模式到底对电脑有什么影响?...
  10. 机器学习流程及详细内容(4)
  11. python拼写检查_python 英语单词拼写检查算法
  12. 哪吒2之大闹东海电影项目亮点怎么样?
  13. SpringCloud-gateway资料以及详解
  14. 异构 ? 系统差异应该成为过去式, 专注在应用和数据 - 异构平台整合策略之1 - SSSD
  15. 搭建自己的知识体系 自我提升
  16. manjaro双系统 windows_Linux manjaro与Windows10双系统安装
  17. 天气预报到底能有多精细?一个小网格里的天气变化
  18. 硬盘柱面损坏怎么办_【已解决】郁闷了。。。笔记本硬盘0柱面坏道。。。分享下教训、经验...
  19. NVIDIA Riva中文手册 (四) —— Riva ASR自动语音识别API的使用
  20. 小米8刷安卓10魔趣Rom

热门文章

  1. 品牌设计工作室html5模板
  2. 失心漂亮的个人html引导页面源码
  3. c# int byte转
  4. 30万条数据,搜索文本字段的各种方式对比
  5. 在Ubuntu上安装mongoDB
  6. codeigniter 辅助函数 - 敏感词过滤
  7. reids的持久化 RDB和AOF
  8. Oracle及Oracle客户端、PLSQL安装的一些问题
  9. 华为机试——明明的随机数
  10. LeetCode 112. Path Sum