多线程(三)

本文主要接着前面多线程的两篇文章总结Java多线程中的线程安全问题。

一.一个典型的Java线程安全例子

 1 public class ThreadTest {
 2
 3     public static void main(String[] args) {
 4         Account account = new Account("123456", 1000);
 5         DrawMoneyRunnable drawMoneyRunnable = new DrawMoneyRunnable(account, 700);
 6         Thread myThread1 = new Thread(drawMoneyRunnable);
 7         Thread myThread2 = new Thread(drawMoneyRunnable);
 8         myThread1.start();
 9         myThread2.start();
10     }
11
12 }
13
14 class DrawMoneyRunnable implements Runnable {
15
16     private Account account;
17     private double drawAmount;
18
19     public DrawMoneyRunnable(Account account, double drawAmount) {
20         super();
21         this.account = account;
22         this.drawAmount = drawAmount;
23     }
24
25     public void run() {
26         if (account.getBalance() >= drawAmount) {  //1
27             System.out.println("取钱成功, 取出钱数为:" + drawAmount);
28             double balance = account.getBalance() - drawAmount;
29             account.setBalance(balance);
30             System.out.println("余额为:" + balance);
31         }
32     }
33 }
34
35 class Account {
36
37     private String accountNo;
38     private double balance;
39
40     public Account() {
41
42     }
43
44     public Account(String accountNo, double balance) {
45         this.accountNo = accountNo;
46         this.balance = balance;
47     }
48
49     public String getAccountNo() {
50         return accountNo;
51     }
52
53     public void setAccountNo(String accountNo) {
54         this.accountNo = accountNo;
55     }
56
57     public double getBalance() {
58         return balance;
59     }
60
61     public void setBalance(double balance) {
62         this.balance = balance;
63     }
64
65 }

上面例子很容易理解,有一张银行卡,里面有1000的余额,程序模拟你和你老婆同时在取款机进行取钱操作的场景。多次运行此程序,可能具有多个不同组合的输出结果。其中一种可能的输出为:

1 取钱成功, 取出钱数为:700.0
2 余额为:300.0
3 取钱成功, 取出钱数为:700.0
4 余额为:-400.0

也就是说,对于一张只有1000余额的银行卡,你们一共可以取出1400,这显然是有问题的。

经过分析,问题在于Java多线程环境下的执行的不确定性。CPU可能随机的在多个处于就绪状态中的线程中进行切换,因此,很有可能出现如下情况:当thread1执行到//1处代码时,判断条件为true,此时CPU切换到thread2,执行//1处代码,发现依然为真,然后执行完thread2,接着切换到thread1,接着执行完毕。此时,就会出现上述结果。

因此,讲到线程安全问题,其实是指多线程环境下对共享资源的访问可能会引起此共享资源的不一致性。因此,为避免线程安全问题,应该避免多线程环境下对此共享资源的并发访问。

二.同步方法

对共享资源进行访问的方法定义中加上synchronized关键字修饰,使得此方法称为同步方法。可以简单理解成对此方法进行了加锁,其锁对象为当前方法所在的对象自身。多线程环境下,当执行此方法时,首先都要获得此同步锁(且同时最多只有一个线程能够获得),只有当线程执行完此同步方法后,才会释放锁对象,其他的线程才有可能获取此同步锁,以此类推...

在上例中,共享资源为account对象,当使用同步方法时,可以解决线程安全问题。只需在run()方法前加上synshronized关键字即可。

1 public synchronized void run() {
2
3     // ....
4
5 }

三.同步代码块

正如上面所分析的那样,解决线程安全问题其实只需限制对共享资源访问的不确定性即可。使用同步方法时,使得整个方法体都成为了同步执行状态,会使得可能出现同步范围过大的情况,于是,针对需要同步的代码可以直接另一种同步方式——同步代码块来解决。

同步代码块的格式为:

1 synchronized (obj) {
2
3     //...
4
5 }

其中,obj为锁对象,因此,选择哪一个对象作为锁是至关重要的。一般情况下,都是选择此共享资源对象作为锁对象。

如上例中,最好选用account对象作为锁对象。(当然,选用this也是可以的,那是因为创建线程使用了runnable方式,如果是直接继承Thread方式创建的线程,使用this对象作为同步锁会其实没有起到任何作用,因为是不同的对象了。因此,选择同步锁时需要格外小心...)

四.Lock对象同步锁

上面我们可以看出,正因为对同步锁对象的选择需要如此小心,有没有什么简单点的解决方案呢?以方便同步锁对象与共享资源解耦,同时又能很好的解决线程安全问题。

使用Lock对象同步锁可以方便的解决此问题,唯一需要注意的一点是Lock对象需要与资源对象同样具有一对一的关系。Lock对象同步锁一般格式为:

 1 class X {
 2
 3     // 显示定义Lock同步锁对象,此对象与共享资源具有一对一关系
 4     private final Lock lock = new ReentrantLock();
 5
 6     public void m(){
 7         // 加锁
 8         lock.lock();
 9
10         //...  需要进行线程安全同步的代码
11
12         // 释放Lock锁
13         lock.unlock();
14     }
15
16 }

 五.wait()/notify()/notifyAll()线程通信

在博文《Java总结篇系列:java.lang.Object》中有提及到这三个方法,虽然这三个方法主要都是用于多线程中,但实际上都是Object类中的本地方法。因此,理论上,任何Object对象都可以作为这三个方法的主调,在实际的多线程编程中,只有同步锁对象调这三个方法,才能完成对多线程间的线程通信。

wait():导致当前线程等待并使其进入到等待阻塞状态。直到其他线程调用该同步锁对象的notify()或notifyAll()方法来唤醒此线程。

notify():唤醒在此同步锁对象上等待的单个线程,如果有多个线程都在此同步锁对象上等待,则会任意选择其中某个线程进行唤醒操作,只有当前线程放弃对同步锁对象的锁定,才可能执行被唤醒的线程。

notifyAll():唤醒在此同步锁对象上等待的所有线程,只有当前线程放弃对同步锁对象的锁定,才可能执行被唤醒的线程。

  1 package com.qqyumidi;
  2
  3 public class ThreadTest {
  4
  5     public static void main(String[] args) {
  6         Account account = new Account("123456", 0);
  7
  8         Thread drawMoneyThread = new DrawMoneyThread("取钱线程", account, 700);
  9         Thread depositeMoneyThread = new DepositeMoneyThread("存钱线程", account, 700);
 10
 11         drawMoneyThread.start();
 12         depositeMoneyThread.start();
 13     }
 14
 15 }
 16
 17 class DrawMoneyThread extends Thread {
 18
 19     private Account account;
 20     private double amount;
 21
 22     public DrawMoneyThread(String threadName, Account account, double amount) {
 23         super(threadName);
 24         this.account = account;
 25         this.amount = amount;
 26     }
 27
 28     public void run() {
 29         for (int i = 0; i < 100; i++) {
 30             account.draw(amount, i);
 31         }
 32     }
 33 }
 34
 35 class DepositeMoneyThread extends Thread {
 36
 37     private Account account;
 38     private double amount;
 39
 40     public DepositeMoneyThread(String threadName, Account account, double amount) {
 41         super(threadName);
 42         this.account = account;
 43         this.amount = amount;
 44     }
 45
 46     public void run() {
 47         for (int i = 0; i < 100; i++) {
 48             account.deposite(amount, i);
 49         }
 50     }
 51 }
 52
 53 class Account {
 54
 55     private String accountNo;
 56     private double balance;
 57     // 标识账户中是否已有存款
 58     private boolean flag = false;
 59
 60     public Account() {
 61
 62     }
 63
 64     public Account(String accountNo, double balance) {
 65         this.accountNo = accountNo;
 66         this.balance = balance;
 67     }
 68
 69     public String getAccountNo() {
 70         return accountNo;
 71     }
 72
 73     public void setAccountNo(String accountNo) {
 74         this.accountNo = accountNo;
 75     }
 76
 77     public double getBalance() {
 78         return balance;
 79     }
 80
 81     public void setBalance(double balance) {
 82         this.balance = balance;
 83     }
 84
 85     /**
 86      * 存钱
 87      *
 88      * @param depositeAmount
 89      */
 90     public synchronized void deposite(double depositeAmount, int i) {
 91
 92         if (flag) {
 93             // 账户中已有人存钱进去,此时当前线程需要等待阻塞
 94             try {
 95                 System.out.println(Thread.currentThread().getName() + " 开始要执行wait操作" + " -- i=" + i);
 96                 wait();
 97                 // 1
 98                 System.out.println(Thread.currentThread().getName() + " 执行了wait操作" + " -- i=" + i);
 99             } catch (InterruptedException e) {
100                 e.printStackTrace();
101             }
102         } else {
103             // 开始存钱
104             System.out.println(Thread.currentThread().getName() + " 存款:" + depositeAmount + " -- i=" + i);
105             setBalance(balance + depositeAmount);
106             flag = true;
107
108             // 唤醒其他线程
109             notifyAll();
110
111             // 2
112             try {
113                 Thread.sleep(3000);
114             } catch (InterruptedException e) {
115                 e.printStackTrace();
116             }
117             System.out.println(Thread.currentThread().getName() + "-- 存钱 -- 执行完毕" + " -- i=" + i);
118         }
119     }
120
121     /**
122      * 取钱
123      *
124      * @param drawAmount
125      */
126     public synchronized void draw(double drawAmount, int i) {
127         if (!flag) {
128             // 账户中还没人存钱进去,此时当前线程需要等待阻塞
129             try {
130                 System.out.println(Thread.currentThread().getName() + " 开始要执行wait操作" + " 执行了wait操作" + " -- i=" + i);
131                 wait();
132                 System.out.println(Thread.currentThread().getName() + " 执行了wait操作" + " 执行了wait操作" + " -- i=" + i);
133             } catch (InterruptedException e) {
134                 e.printStackTrace();
135             }
136         } else {
137             // 开始取钱
138             System.out.println(Thread.currentThread().getName() + " 取钱:" + drawAmount + " -- i=" + i);
139             setBalance(getBalance() - drawAmount);
140
141             flag = false;
142
143             // 唤醒其他线程
144             notifyAll();
145
146             System.out.println(Thread.currentThread().getName() + "-- 取钱 -- 执行完毕" + " -- i=" + i); // 3
147         }
148     }
149
150 }

上面的例子演示了wait()/notify()/notifyAll()的用法。部分输出结果为:

 1 取钱线程 开始要执行wait操作 执行了wait操作 -- i=0
 2 存钱线程 存款:700.0 -- i=0
 3 存钱线程-- 存钱 -- 执行完毕 -- i=0
 4 存钱线程 开始要执行wait操作 -- i=1
 5 取钱线程 执行了wait操作 执行了wait操作 -- i=0
 6 取钱线程 取钱:700.0 -- i=1
 7 取钱线程-- 取钱 -- 执行完毕 -- i=1
 8 取钱线程 开始要执行wait操作 执行了wait操作 -- i=2
 9 存钱线程 执行了wait操作 -- i=1
10 存钱线程 存款:700.0 -- i=2
11 存钱线程-- 存钱 -- 执行完毕 -- i=2
12 取钱线程 执行了wait操作 执行了wait操作 -- i=2
13 取钱线程 取钱:700.0 -- i=3
14 取钱线程-- 取钱 -- 执行完毕 -- i=3
15 取钱线程 开始要执行wait操作 执行了wait操作 -- i=4
16 存钱线程 存款:700.0 -- i=3
17 存钱线程-- 存钱 -- 执行完毕 -- i=3
18 存钱线程 开始要执行wait操作 -- i=4
19 取钱线程 执行了wait操作 执行了wait操作 -- i=4
20 取钱线程 取钱:700.0 -- i=5
21 取钱线程-- 取钱 -- 执行完毕 -- i=5
22 取钱线程 开始要执行wait操作 执行了wait操作 -- i=6
23 存钱线程 执行了wait操作 -- i=4
24 存钱线程 存款:700.0 -- i=5
25 存钱线程-- 存钱 -- 执行完毕 -- i=5
26 存钱线程 开始要执行wait操作 -- i=6
27 取钱线程 执行了wait操作 执行了wait操作 -- i=6
28 取钱线程 取钱:700.0 -- i=7
29 取钱线程-- 取钱 -- 执行完毕 -- i=7
30 取钱线程 开始要执行wait操作 执行了wait操作 -- i=8
31 存钱线程 执行了wait操作 -- i=6
32 存钱线程 存款:700.0 -- i=7

由此,我们需要注意如下几点:

1.wait()方法执行后,当前线程立即进入到等待阻塞状态,其后面的代码不会执行;

2.notify()/notifyAll()方法执行后,将唤醒此同步锁对象上的(任意一个-notify()/所有-notifyAll())线程对象,但是,此时还并没有释放同步锁对象,也就是说,如果notify()/notifyAll()后面还有代码,还会继续进行,知道当前线程执行完毕才会释放同步锁对象;

3.notify()/notifyAll()执行后,如果右面有sleep()方法,则会使当前线程进入到阻塞状态,但是同步对象锁没有释放,依然自己保留,那么一定时候后还是会继续执行此线程,接下来同2;

4.wait()/notify()/nitifyAll()完成线程间的通信或协作都是基于不同对象锁的,因此,如果是不同的同步对象锁将失去意义,同时,同步对象锁最好是与共享资源对象保持一一对应关系;

5.当wait线程唤醒后并执行时,是接着上次执行到的wait()方法代码后面继续往下执行的。

当然,上面的例子相对来说比较简单,只是为了简单示例wait()/notify()/noitifyAll()方法的用法,但其本质上说,已经是一个简单的生产者-消费者模式了

时间: 2024-10-24 10:09:08

多线程(三)的相关文章

多线程(三) java中线程的简单使用

============================================= 原文链接:多线程(三) java中线程的简单使用 转载请注明出处! ============================================= java中,启动线程通常是通过Thread或其子类通过调用start()方法启动. 常见使用线程有两种:实现Runnable接口和继承Thread.而继承Thread亦或使用TimerTask其底层依旧是实现了Runnabel接口.考虑到java的

win32多线程(三) 死锁

任何时候当一段代码需要两个(或更多)资源时,都有潜在性的死锁. void SwapLists(List *list1, List *list2) { List *tmp_list; EnterCriticalSection(list1->m_section); EnterCriticalSection(list2->m_section); tmp->list = list1->head; list1->head = list2->head; list2->head

IO复用、多进程和多线程三种并发编程模型

I/O复用模型 I/O复用原理:让应用程序可以同时对多个I/O端口进行监控以判断其上的操作是否可以进行,达到时间复用的目的.在书上看到一个例子来解释I/O的原理,我觉得很形象,如果用监控来自10根不同地方的水管(I/O端口)是否有水流到达(即是否可读),那么需要10个人(即10个线程或10处代码)来做这件事.如果利用某种技术(比如摄像头)把这10根水管的状态情况统一传达到某一点,那么就只需要1个人在那个点进行监控就行了,而类似与select或epoll这样的多路I/O复用机制就好比是摄像头的功能

java多线程三之线程协作与通信实例

多线程的难点主要就是多线程通信协作这一块了,前面笔记二中提到了常见的同步方法,这里主要是进行实例学习了,今天总结了一下3个实例: 1.银行存款与提款多线程实现,使用Lock锁和条件Condition.     附加 : 用监视器进行线程间通信 2.生产者消费者实现,使用LinkedList自写缓冲区. 3.多线程之阻塞队列学习,用阻塞队列快速实现生产者消费者模型.    附加:用布尔变量关闭线程        在三种线程同步方法中,我们这里的实例用Lock锁来实现变量同步,因为它比较灵活直观.

Java多线程(三)

本文主要接着前面多线程的两篇文章总结Java多线程中的线程安全问题. 一.一个典型的Java线程安全例子 1 public class ThreadTest { 2 3 public static void main(String[] args) { 4 Account account = new Account("123456", 1000); 5 DrawMoneyRunnable drawMoneyRunnable = new DrawMoneyRunnable(account,

Java多线程——&lt;三&gt;简单的线程执行:Executor

一.概述 按照<Java多线程——<一><二>>中所讲,我们要使用线程,目前都是显示的声明Thread,并调用其start()方法.多线程并行,明显我们需要声明多个线程然后都调用他的start方法,这么一看,似乎有些问题:第一.线程一旦多了,声明势必是个问题:第二.多线程启动如果通过手动执行的话,那可能一个线程已经跑完了,另外一个还没起来(我推测可能会出现这个问题).所以,我们在想,如果有个管家,能够帮我们管理这么多线程,只需要把我们定义的任务交给管家,管家就能够帮我们

多线程三:Thread API,ThreadLocal,synchronized,volatile和Condition

一.Thread API: setDefaultUncaughtExceptionHandler(Thread.UncaughtExceptionHandler eh) 首先要了解什么是Thread.UncaughtExceptionHandler,默认来说当线程出现未捕获的异常时,会中断并抛出异常,抛出后的动作只有简单的堆栈输出.如: public class ThreadTest{ public static void main(String[] args) throws Exception

分布式、高并发和多线程三个概念的简单区分

每当提起分布式.高并发和多线程这三个概念的时候,很多的程序员都会认为分布式=高并发=多线程,即认为这三个概念是相同的,但实际上这种认为是错误的. 什么是分布式 关于分布式的概念,我们大可以如此理解:它是为了解决性能瓶颈问题以及单个物理服务器容量不足问题所采用的优化手段. 而分布式这个领域需要解决极多的问题,且这些问题都在不同的技术层面上,包括分布式文件系统.分布式缓存.分布式数据库和分布式计算等.一些名词如Hadoop.Zookeeper和MQ等也都都跟分布式有关. 如果从理念层面看待,分布式的

多线程(三)

线程的四种状态 1 产生(new):线程对象已经产生但是尚未被启动,所以无法执行,通过new产生对象后没有对它调用start()方法. 2 可执行(Runnable):每一个支持多线程的系统都有一个排程器,排程器会从线程池中选择一个线程并且启动它,当一个线程处于可执行状态的时候时候,表示它可能处于线程池中等待排程器启动它:也有可能它正在执行.如执行了一个线程对象的start()方法后,线程就处于可执行状态.但是,显然线程可能并不是在执行中.具备了执行权限,但并没有执行. 3 停滞(Blocks)

java多线程(三)-Executors实现的几种线程池以及Callable

从java5开始,类库中引入了很多新的管理调度线程的API,最常用的就是Executor(执行器)框架.Executor帮助程序员管理Thread对象,简化了并发编程,它其实就是在 提供了一个中间层,方便程序员管理异步任务的执行,而又不用显式的管理线程的生命周期. Executor采用了线程池实现,也更节约开销,因为是我们启动新线程的首选方法. 示例代码:src/thread_runnable/CachedThreadPool.java 1 public class CachedThreadPo