`
zhangyeny
  • 浏览: 30523 次
  • 性别: Icon_minigender_1
  • 来自: 厦门
社区版块
存档分类
最新评论

java并发中Lock和Synchronized的异同

 
阅读更多
java中可以使用Lock和Synchronized的可以实现对某个共享资源的同步,同时也可以实现对某些过程的原子性操作
Lock可以使用Condition进行线程之间的调度
Synchronized则使用Object对象本身的notify, wait, notityAll调度机制
这两种调度机制有什么异同呢?
Condition是Java5以后出现的机制,它有更好的灵活性,而且在一个对象里面可以有多个Condition(即对象监视器),则线程可以注册在不同的Condition,从而可以有选择性的调度线程,更加灵活。
Synchronized就相当于整个对象只有一个单一的Condition(即该对象本身)所有的线程都注册在它身上,线程调度的时候之后调度所有得注册线程,没有选择权,会出现相当大的问题
下面是一个场景,针对这个场景提出两种解决方案。
一个中转站,可以接纳货物,然后发出货物,这是需要建一个仓库,相当于一个缓冲区,当仓库满的时候,不能接货,仓库空的时候,不能发货。
第一种,用一个Condition去解决,有可能会出问题

package com.zxx;

import java.util.Random;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

/**
 * 单个Condition去控制一个缓冲区,多线程对缓冲区做读写操作,要保证缓冲区满的时侯不会
 * 被写,空的时候不会被读;单个Condition控制会出错误: 当缓冲区还有一个位置时,多个写线程
 * 同时访问,则只有一个写线程可以对其进行写操作,操作完之后,唤醒在这个condition上等待的
 * 其他几个写线程,如果判断用IF语句的话就会出现继续向缓冲区添加。
 * @author Administrator
 *
 */
public class ConditionError {
	Lock lock = new ReentrantLock();
	Condition condition = lock.newCondition();
	String[] container = new String[10];
	int index = 0;
	public static void main(String[] args) {
		ConditionError conditionError = new ConditionError();
		conditionError.test();
	}
	
	public void test(){
		ExecutorService threadPool = Executors.newCachedThreadPool();
		for(int i = 0; i < 14; i++){//先用14个线程去写,则有4个线程会被阻塞
			threadPool.execute(new Runnable(){

				@Override
				public void run() {
					put();
				}
				
			});
		}
		
		Executors.newSingleThreadExecutor().execute(new Runnable(){//用一个线程去取,则会通知4个阻塞的写线程工作,此时
																//会有一个线程向缓冲区写,写完后去通知在这个condition上等待
																//的取线程,这是它的本意,但是它唤醒了写线程,因为只有一个condition
																//不能有选择的唤醒写取线程,此时就需要有多个Condition
			@Override
			public void run() {
				try {
					Thread.sleep(10000);
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
				get();
			}
			
		});
	}
	
	/**
	 * 向缓冲去写数据
	 */
	public void put(){
		lock.lock();
		try{
			System.out.println(Thread.currentThread().getName() + "当前位置:" + index + "-----------------------------");
			while(index == 10){
				try {
					System.out.println(Thread.currentThread().getName() + "处于阻塞状态!");
					condition.await();
//					index = 0;
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
			container[index] = new String(new Random().nextInt() + "");
			condition.signalAll();
			index ++;
		} finally {
			lock.unlock();
		}
	}
	
	/**
	 * 从缓冲区拿数据
	 */
	public void get(){
		lock.lock();
		try{
			while(index == 0){
				try {
					System.out.println("get--------" + Thread.currentThread().getName() + "处于阻塞");
					condition.await();
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
			index --;
			System.out.println("get---------" + Thread.currentThread().getName() + "唤醒阻塞");
			condition.signalAll();
			
			
		} finally {
			
			lock.unlock();
		}
	}
}


第二种解决方案,用java api中的 一个例子
 class BoundedBuffer {
   final Lock lock = new ReentrantLock();
   final Condition notFull  = lock.newCondition(); 
   final Condition notEmpty = lock.newCondition(); 

   final Object[] items = new Object[100];
   int putptr, takeptr, count;

   public void put(Object x) throws InterruptedException {
     lock.lock();
     try {
       while (count == items.length) 
         notFull.await();
       items[putptr] = x; 
       if (++putptr == items.length) putptr = 0;
       ++count;
       notEmpty.signal();
     } finally {
       lock.unlock();
     }
   }

   public Object take() throws InterruptedException {
     lock.lock();
     try {
       while (count == 0) 
         notEmpty.await();
       Object x = items[takeptr]; 
       if (++takeptr == items.length) takeptr = 0;
       --count;
       notFull.signal();
       return x;
     } finally {
       lock.unlock();
     }
   } 
 }



请注意,

(ArrayBlockingQueue 类提供了这项功能,因此没有理由去实现这个示例类。)
[size=medium][/size]
分享到:
评论

相关推荐

    Java并发编程系列- synchronized

    Java并发编程系列- synchronized;Java并发编程系列- synchronized;Java并发编程系列- synchronized;

    java的lock和synchronized的区别.docx

    基础理论知识,描述lock和synchronized的区别和基础的理论,其中还有死锁等基础概念。

    【Java面试题】lock与synchronized区别

    【Java面试题】lock与synchronized区别

    Java 并发核心编程

    本文的主题是关于具有java语言风格的Thread、synchronized、volatile,以及J2SE5中新增的概念,如锁(Lock)、原子性(Atomics)、并发集合类、线程协作摘要、Executors。开发者通过这些基础的接口可以构建高并发、线程...

    Java并发编程---synchronized关键字

    Java并发编程---synchronized关键

    java中synchronized用法

    java中synchronized用法

    深入java并发编程,使用ReentrantLock和 Synchronized加锁

    深入java并发编程,使用ReentrantLock和 Synchronized加锁

    【Java并发编程】Synchronized关键字实现原理.doc

    【Java并发编程】Synchronized关键字实现原理.doc

    java锁机制Synchronizedjava锁机制Synchronized

    java锁机制Synchronized java锁机制Synchronized java锁机制Synchronized java锁机制Synchronized

    lock锁,lock锁和synchronized的对比

    lock锁,lock锁和synchronized的对比 # Lock锁 JDK5.0后Java提供了一种更加强大的线程同步机制。一种显式定义同步锁对象来实现锁,提供了对共享资源的独占访问,每次只能有一个线程对Lock对象加锁,线程开始访问...

    Synchronized 和 Lock 的区别和使用场景

    并发编程中,锁是经常需要用到的,今天我们一起来看下Java中的锁机制:synchronized和lock。 Synchronized 和 Lock的概念 Synchronized 是Java 并发编程中很重要的关键字,另外一个很重要的是 volatile。Syncronized...

    java中的Lock类和Condition类.docx

    在jdk1.5以后,JAVA提供了Lock类来实现和synchronized一样的功能,并且还提供了Condition来显示线程间通信。 Lock类是Java类来提供的功能,丰富的api使得Lock类的同步功能比synchronized的同步更强大。本文章的所有...

    java并发编程面试题

    并行和并发有什么区别? 什么是上下文切换? 线程和进程区别 什么是线程和进程? 创建线程有哪几种方式?,如何避免线程死锁 线程的 run()和 start()有什么区别? 什么是 Callable 和 Future? 线程的调度策略 sleep...

    java中synchronized的使用

    java中synchronized的使用,java中的锁锁的到底是什么?是括号里的代码块吗?肯定不是的;

    Java并发编程:设计原则与模式(第二版)

    读者将通过使用java.lang.thread类、synchronized和volatile关键字,以及wait、notify和notifyall方法,学习如何初始化、控制和协调并发操作。此外,本书还提供了有关并发编程的全方位的详细内容,例如限制和同步、...

    java并发编程

    , 这里,读者将通过使用java.lang.thread类、synchronized和volatile关键字,以及wait、notify和notifyall方法,学习如何初始化、控制和协调并发操作。此外,本书还提供了有关并发编程的全方位的详细内容,例如限制...

    龙果java并发编程完整视频

    第49节Java中的阻塞队列原理与使用00:26:18分钟 | 第50节实战:简单实现消息队列00:11:07分钟 | 第51节并发容器ConcurrentHashMap原理与使用00:38:22分钟 | 第52节线程池的原理与使用00:42:49分钟 | 第53节...

    Java并发机制的底层实现原理.pdf

    主要总结了:本地内存和线程安全的问题、volatile、synchronized、处理器实现并发的方式、Java实现并发的方式。

    深入理解Java并发之synchronized实现原理.docx

    在 Java 中,关键字 synchronized可以保证在同一个时刻,只有一个线程可以执行某个方法或者某个代码块(主要是对方法或者代码块中存在共享数据的操作),同时我们还应该注意到synchronized另外一个重要的作用,...

Global site tag (gtag.js) - Google Analytics