`
chairmanMao
  • 浏览: 16105 次
  • 性别: Icon_minigender_1
  • 来自: 郑州
社区版块
存档分类
最新评论

Java concurrent学习

阅读更多
    昨天复习了一下Java多线程,最近找工作时总是有人问到java concurrent包,所以就学习了一下,学习逻辑基本是"映射式",就是看原Java提供的多线程\同步在java concurrent中是怎么实现的,经比较感觉无区别,有原来java多线程基础理解concurrent的操作无压力,现在用concurrent同步类重写http://blog.csdn.net/zyplus/article/details/6672775的问题
    代码如下:
   
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

/**
 *@author zzf
 */

public class Test_15 {
public static void main(String[] args) throws InterruptedException{
	Lock alock=new ReentrantLock();
	Lock block=new ReentrantLock();
	Lock clock=new ReentrantLock();
	Condition acon=alock.newCondition();
	Condition bcon=block.newCondition();
	Condition ccon=clock.newCondition();
	
	PrintChar p1 = new PrintChar("A",alock,clock,acon,ccon);
	PrintChar p2 = new PrintChar("B",block,alock,bcon,acon);
	PrintChar p3 = new PrintChar("C",clock,block,ccon,bcon);
	Thread t1 = new Thread(p1);
	Thread t2 = new Thread(p2);
	Thread t3 = new Thread(p3);
	t1.start();
	Thread.sleep(50);
	t2.start();
	Thread.sleep(50);
	t3.start();
	Thread.sleep(50);
}
}
class PrintChar implements Runnable{
    private String name;
    private Lock self;
    private Lock prev;
    private Condition conSelf;
    private Condition conPrev;
    public PrintChar(String name,Lock self,Lock prev,Condition conSelf,Condition conPrev){
    	this.name=name;
    	this.self=self;
    	this.prev=prev;
    	this.conSelf=conSelf;
    	this.conPrev=conPrev;
    }
	@Override
	public void run() {
		int count=10;
		while(count>0){
			prev.lock();
			self.lock();
			try{
			System.out.println("name:"+name);
			count--;
			conSelf.signal();
			}catch(Exception e){
				e.printStackTrace();
			}finally{
				self.unlock();
			}
			try{
				if(count>0)
				conPrev.await();
			}catch(Exception e){
				e.printStackTrace();
			}finally{
				prev.unlock();
			}
		}
		
		
	}
	
}
    
分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics