Java之ReentrantLock公平锁和非公平锁

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

在Java的ReentrantLock构造函数中提供了两种锁：创建公平锁和非公平锁（默认）。代码如下：

public ReentrantLock() {
sync = new NonfairSync();
} public ReentrantLock(boolean fair) {
sync = fair ? new FairSync() : new NonfairSync();
}

此例可反应公平锁和非公平锁的差异:

package concurrency;import java.util.concurrent.locks.ReentrantLock;/**
* @author yuanxu
* Apr 11, 2017 9:59:24 PM
*/
public class ReentrantLockTest {
private static final ReentrantLock lock = new ReentrantLock();
private static final ReentrantLock fairlock = new ReentrantLock(true);
private int n; public static void main(String[] args) {
// TODO Auto-generated method stub
ReentrantLockTest rlt = new ReentrantLockTest();
for (int i=0; i<100; i++) {
Thread nonT = new Thread(new NonFairTestThread(rlt));
nonT.setName("nonFair[" + (i + 1) + "]");
nonT.start(); Thread fairT = new Thread(new FairTestThread(rlt));
fairT.setName("fair[" + (i + 1) + "]");
fairT.start();
}
} static class NonFairTestThread implements Runnable {
private ReentrantLockTest rlt; public NonFairTestThread(ReentrantLockTest rlt) {
this.rlt = rlt;
} public void run() {
lock.lock();
try {
rlt.setNum(rlt.getNum() + 1);
System.out.println(Thread.currentThread().getName()
+ " nonfairlock***************" + rlt.getNum());
} finally {
lock.unlock();
}
}
} static class FairTestThread implements Runnable {
private ReentrantLockTest rlt; public FairTestThread(ReentrantLockTest rlt) {
this.rlt = rlt;
} public void run() {
fairlock.lock();
try {
rlt.setNum(rlt.getNum() + 1);
System.out.println(Thread.currentThread().getName()
+ " fairlock=======" + rlt.getNum() + " "
+ fairlock.getHoldCount() + " queuelength="
+ fairlock.getQueueLength());
} finally {
fairlock.unlock();
}
}
} public void setNum(int n) {
this.n = n;
} public int getNum() {
return n;
}}