(三)java线程:线程同步ReentrantLock,condition(await,signal)

标签: java 线程 线程 | 发表时间:2014-08-23 09:19 | 作者:
出处:http://www.iteye.com

(三)线程同步ReentrantLock,condition(await,signal)

一.synchronized和 ReentrantLock 故事

1. 我们前面 (二)java 的线程同步(synchronized ,wait,notify 讲了synchronized的同步方法,java 就是这么神奇,这里又有一个同步的方法!当然,长江后浪推前浪,后者肯定比前者是由优越之处的。

先看看   synchronized  的一些限制: 
     1.1 :无法中断正在等候获取一个锁的线程 
     1.2 :无法通过投票得到一个锁 
     1.3 :释放锁的操作只能与获得锁所在的代码块中进行,无法在别的代码块中释放锁 。

 

  ReentrantLock  实现了  Lock ,它拥有与  synchronized 相同的并发性和内存语义,但是添加了类似 锁投票定时锁等候可中断锁等候的一些特性。此外,它还提供了在激烈争用情况下更佳的性能。

定时锁等候:设置定时等候之后,在这个等候时间内如果没有获得这个锁,这个线程就会自己中断。

可中断锁等候:就是线程等候可以自己中断也可以别人中断。

锁投票:这个不太懂,有懂的大牛给提示一下,我到时引用到博文里面来(会注明作者的)。

 

二. ReentrantLock 的简单用法:

       1.lock() 和unlock():ReentrantLock手动获取和释放锁,一般放在try catch 块中。如下所示

class X {
   private final ReentrantLock lock = new ReentrantLock();
   // ...
 
   public void m() {
     lock.lock();  // block until condition holds
     try {
       // ... 同步的代码
     } finally {
       lock.unlock()
     }
   }
 }

 

    2.既然有锁,那多个线程下面的阻塞注明做到呢?这就需要用到Condiction类了,这个类的作用就相当于给ReentrantLock加类似synchronized的wait,notify方法,不过它更强大!它的await可以有条件的等待,比如定时等待等用法,为方便比较,我结合前面synchronized的例子改一下,例子如下所示:

 

package com.hxw.Threads;

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.ReentrantLock;

public class ProducerConsumeGameLock {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		Bucket bucket = new Bucket(); // 构造篮子
		new Thread(new Producer(bucket),"Producer线程").start();
		new Thread(new Consumer(bucket),"Consumer线程").start();
	}

}

final class Consumer implements Runnable {
	private Bucket bucket;

	public Consumer(Bucket bucket) {
		this.bucket = bucket;
	}

	@Override
	public void run() {
		for (int i = 0; i < 10; i++) {
			bucket.get();
		}
	}

}

final class Producer implements Runnable {
	private Bucket bucket;

	public Producer(Bucket bucket) {
		this.bucket = bucket;
	}

	@Override
	public void run() {
		for (int i = 0; i < 10; i++) { // 来回十次交易
			bucket.put((int) (Math.random() * 1000));
		}
	}
}

class Bucket {
	private int packOdBalls;
	private boolean available = false;
	private final ReentrantLock lock = new ReentrantLock();
	private Condition noBull = lock.newCondition();
	private Condition fullBull = lock.newCondition();

	public int get() { // 消费者从篮子里面取出球
		lock.lock();
		try {
			while (available == false) { // 如果没有就等着,但是为什么不是if呢?后面会做解析
				System.out.println("消费者:暂时没有球可以消费我就等着...");
				noBull.await(); // wait();
			}
			System.out.println("消费者获得了" + packOdBalls + "个球");
			available = false;
			System.out.println("持有消费线程数: "+lock.getHoldCount());
			fullBull.signal(); // notify();
		} catch (InterruptedException e) {
			e.printStackTrace();
		} finally {
			lock.unlock();
		}
		// 有的话就取出来
		return packOdBalls;
	}

	public synchronized void put(int packOdBalls) { // 生产者将生产球并放入到篮子里面
		lock.lock();
		try {
			while (available) {
				System.out.println("生产者:既然篮子里面已经有球了我就消费完了再生产吧!");
				fullBull.await(); // wait();
			}
			this.packOdBalls = packOdBalls;
			available = true;
			System.out.println("生产者放进去了" + packOdBalls + "个球");
			noBull.signal(); // notify();
		} catch (InterruptedException e) {
			e.printStackTrace();
		} finally {
			lock.unlock();
		}

	}

}

 

【运行结果与前面一样,需要看的可以戳文章头的链接】

 

三.ReentrantLock的方法…

  1. public boolean tryLock():

仅在调用时锁未被另一个线程保持的情况下,才获取该锁。 这个方法会完全忽略公平策略,理解trylock的意思就知道了,就是“努力试着去锁”,所以一旦这个锁没有线程持有,他就抢占了!

2. public boolean tryLock(long timeout,TimeUnit unit):

如果锁在给定等待时间内没有被另一个线程保持,且当前线程未被中断,则获取该锁。 说的详细点如果超出了指定的等待时间,则返回值为 false。如果该锁没有被另一个线程保持,并且立即返回 true 值,则将锁的保持计数设置为 1。如果为了使用公平的排序策略,已经设置此锁,并且其他线程都在等待该锁,则不会 获取一个可用的锁。这与 tryLock() 方法相反。如果想使用一个允许闯入公平锁的定时 tryLock,那么可以将定时形式和不定时形式组合在一起:

if (lock.tryLock() || lock.tryLock(timeout, unit) ) { ... }

注意:有的人可能不理解这两个参数,其实就是前面是数词,后面是量词(SECOND,HOUR等等)

3. public int getHoldCount()查询当前线程保持此锁的次数。

4. public boolean isLocked()查询此锁是否由任意线程保持。

等等还有很多方法,这些查询方法都只能叫 监控方法,因为线程无时无刻不在变化,可能返回这个值的下一纳秒,这个值就变了

5.还有一个构造方法:

public ReentrantLock(boolean fair)

创建一个具有给定公平策略的 ReentrantLock。

 

四.Condition方法一览…

1.await():

让当前线程一直处于等待状态,直到唤醒或中断。 需要注意的是,这里说的是当前线程,这个“当前”指的是这个await所属Condition对象的线程创建者,这一点从上面的源码也可以看出(我们每个线程都new了一个Condition)。

对于唤醒,这里有个虚假唤醒,虚假唤醒也会引起当前线程唤醒,我们后面来讨论

2. boolean await(long time,TimeUnit unit)

让当前线程在指定时间内一直处于等待状态,直到被唤醒或中断。

3. void signal() 唤醒一个等待线程。这个与notify功能类似

4. void signalAll() 唤醒所有等待线程。这个与notifyAll功能类似

 

五.虚假唤醒

虚假唤醒简而言之就是一个signal()可能唤醒了多个线程,前面代码第60行左右提到过。当然这个概率是很低的,你会发现,你把while改成if也是可以运行的。但是我们也要避免这种情况,所以我们就改成了while,while()不仅仅在等待条件变量前检查条件变量,实际上在等待条件变量后也检查条件变量。

 

这样对condition进行多做一次判断,即可避免“虚假唤醒”.



已有 0 人发表留言,猛击->> 这里<<-参与讨论


ITeye推荐



相关 [java 线程 线程] 推荐:

Java线程池

- - 企业架构 - ITeye博客
线程的使用在java中占有极其重要的地位,在jdk1.4极其之前的jdk版本中,关于线程池的使用是极其简陋的. 在jdk1.5之后这一情况有了很大的改观. Jdk1.5之后加入了java.util.concurrent包,这个包中主要介绍java中线程以及线程池的使用. 为我们在开发中处理线程的问题提供了非常大的帮助.

Java 线程池

- - 编程语言 - ITeye博客
在项目中,系统启动一个新线程的成本是比较高的,因为它涉及与操作系统交互. 在这种情形下,使用线程池可以很好地提高性能,尤其是当程序中需要创建大量生存周期很短的线程时,更应该考虑使用线程池. 使用线程池可以有效地控制系统中并发线程的数量,当系统中包含大量并发线程时,会导致系统性能剧烈下降,甚至导致JVM崩溃,而线程池的最大线程数参数可以控制系统中并发线程数不超过此数.

Java Thread多线程

- - CSDN博客推荐文章
Java Thread多线程. Java 多线程例子1 小例子. super("zhuyong");//设置线程的名字,默认为“TestThread”. Java 多线程例子2 前台线程(用户线程) 后台线程(守护线程 ). 1,setDaemon(true)后就是后台线程(守护线程 ),反之就是前台线程(用户线程).

Java线程之FutureTask

- - zzm
FutureTask是Future和Callable的结合体. 然后通过Future来取得计算结果. 但是,若开启了多个任务,我们无从知晓哪个任务最先结束,因此,若要实现“当某任务结束时,立刻做一些事情,例如记录日志”这一功能,就需要写一些额外的代码. FutureTask正是为此而存在,他有一个回调函数protected void done(),当任务结束时,该回调函数会被触发.

Java多线程之synchronized

- - CSDN博客推荐文章
这里通过三个测试类阐述了synchronized应用的不同场景. 首先是最基本的synchronized Method的使用.  * @see 概述:Java中的每个对象都有一个锁(lock)或者叫做监视器(monitor) .  * @see 说明:当synchronized关键字修饰一个方法时,则该方法为同步方法 .

java线程池分析

- - BlogJava-首页技术区
    在Java 5.0之前启动一个任务是通过调用Thread类的start()方法来实现的,任务的提于交和执行是同时进行的,如果你想对任务的执行进行调度或是控制 同时执行的线程数量就需要额外编写代码来完成. 5.0里提供了一个新的任务执行架构使你可以轻松地调度和控制任务的执行,并且可以建立一个类似数据库连接 池的线程池来执行任务.

java线程取消方式

- - 编程语言 - ITeye博客
JAVA任务取消方式一般有2种. 第一种设置某个取消标志,任务定期查看该标志,这种方式存在任务取消并不能保证任务立即取消,更糟糕的是有可能任务永远不会结束. 第二种是利用的中断机制,JVM并不能保证阻塞方法检测到中断的速度,但是实际中还是非常快的. 实例一(使用取消标志,会发现取消的任务还执行中,只有执行完再次检测标志任务才取消).

Java线程池应用

- - CSDN博客架构设计推荐文章
1.减少了创建和销毁线程的次数,每个工作线程都可以被重复利用,可执行多个任务. 2.可以根据系统的承受能力,调整线程池中工作线线程的数目,防止因为消耗过多的内存,而把服务器累趴下(每个线程需要大约1MB内存,线程开的越多,消耗的内存也就越大,最后死机). Java里面线程池的顶级接口是Executor,但是严格意义上讲Executor并不是一个线程池,而只是一个执行线程的工具.

Java线程池总结

- - Java - 编程语言 - ITeye博客
  假设一个服务器完成一项任务所需时间为:T1 创建线程时间,T2 在线程中执行任务的时间,T3 销毁线程时间. 当T1 + T3 远大于 T2时,采用多线程技术可以显著减少处理器单元的闲置时间,增加处理器单元的吞吐能力.     线程池就是一个线程的容器,每次只执行额定数量的线程, 线程池作用就是限制系统中执行线程的数量.

java多线程总结

- - Java - 编程语言 - ITeye博客
在java中要想实现多线程,有两种手段,一种是继续Thread类,另外一种是实现Runable接口. 对于直接继承Thread的类来说,代码大致框架是:. class 类名 extends Thread{. * @author Rollen-Holt 继承Thread类,直接调用run方法.             System.out.println(name + "运行     " + i);.