java Lock 以及lockInterruptibly_JAVA

您所在的位置：程序员俱乐部 > 编程开发 > JAVA > java Lock 以及lockInterruptibly

java Lock 以及lockInterruptibly

2014/8/14 13:00:39 gotowqj 程序员俱乐部我要评论(0)

摘要：Lock接口的线程请求锁的几个方法：lock(),拿不到lock就不罢休，不然线程就一直block。比较无赖的做法。tryLock()，马上返回，拿到lock就返回true，不然返回false。比较潇洒的做法。带时间限制的tryLock()，拿不到lock，就等一段时间，超时返回false。比较聪明的做法。下面的lockInterruptibly()就稍微难理解一些。先说说线程的打扰机制，每个线程都有一个打扰标志。这里分两种情况，1.线程在sleep或wait,join
标签：Java

Lock接口的线程请求锁的几个方法：

lock(), 拿不到lock就不罢休，不然线程就一直block。比较无赖的做法。
tryLock()，马上返回，拿到lock就返回true，不然返回false。比较潇洒的做法。
带时间限制的tryLock()，拿不到lock，就等一段时间，超时返回false。比较聪明的做法。

下面的lockInterruptibly()就稍微难理解一些。

先说说线程的打扰机制，每个线程都有一个打扰标志。这里分两种情况，
1. 线程在sleep或wait,join，此时如果别的进程调用此进程的 interrupt（）方法，此线程会被唤醒并被要求处理InterruptedException；(thread在做IO操作时也可能有类似行为，见java thread api)
2. 此线程在运行中，则不会收到提醒。但是此线程的 “打扰标志”会被设置，可以通过isInterrupted()查看并作出处理。

lockInterruptibly()和上面的第一种情况是一样的，线程在请求lock并被阻塞时，如果被interrupt，则“此线程会被唤醒并被要求处理InterruptedException”。

我写了几个test，验证一下：

1). lock()忽视interrupt(), 拿不到锁就一直阻塞：

@Test
publicvoid test3()throwsException{
? ? finalLock lock=newReentrantLock();
? ? lock.lock();
? ? Thread.sleep(1000);
? ? Thread t1=newThread(newRunnable(){
? ? ? ? @Override
? ? ? ? publicvoid run(){
? ? ? ? ? ? lock.lock();
? ? ? ? ? ? System.out.println(Thread.currentThread().getName()+" interrupted.");
? ? ? ? }
? ? });
? ? t1.start();
? ? Thread.sleep(1000);
? ? t1.interrupt();
? ? Thread.sleep(1000000);
}

可以进一步在Eclipse debug模式下观察，子线程一直阻塞。

2). lockInterruptibly()会响应打扰并catch到InterruptedException

@Test
publicvoid test4()throwsException{
? ? finalLock lock=newReentrantLock();
? ? lock.lock();
? ? Thread.sleep(1000);
? ? Thread t1=newThread(newRunnable(){
? ? ? ? @Override
? ? ? ? publicvoid run(){
? ? ? ? ? ? try{
? ? ? ? ? ? ? ? lock.lockInterruptibly();
? ? ? ? ? ? }catch(InterruptedException e){
? ? ? ? ? ? ? ? ? ? ? ? System.out.println(Thread.currentThread().getName()+" interrupted.");
? ? ? ? ? ? }
? ? ? ? }
? ? });
? ? t1.start();
? ? Thread.sleep(1000);
? ? t1.interrupt();
? ? Thread.sleep(1000000);
}

3). 以下实验验证：当线程已经被打扰了（isInterrupted()返回true）。则线程使用lock.lockInterruptibly()，直接会被要求处理InterruptedException。

@Test
publicvoid test5()throwsException{
? ? finalLock lock=newReentrantLock();
? ? Thread t1=newThread(newRunnable(){
? ? ? ? @Override
? ? ? ? publicvoid run(){
? ? ? ? ? ? try{
? ? ? ? ? ? ? ? Thread.sleep(2000);
? ? ? ? ? ? ? ? lock.lockInterruptibly();
? ? ? ? ? ? }catch(InterruptedException e){
? ? ? ? ? ? ? ? System.out.println(Thread.currentThread().getName()+" interrupted.");
? ? ? ? ? ? }
? ? ? ? }
? ? });
? ? t1.start();
? ? t1.interrupt();
? ? Thread.sleep(10000000);
} ?