Java5的线程并发库中,提供了相应的线程锁接口Lock来帮助我们同步处理。Lock比传统线程模型中的synchronized更加面向对象,锁本身也是一个对象,两个线程执行的代码要实现同步互斥效果,就要使用同一个锁对象。锁要上在要操作的资源类的内部方法中,而不是线程代码中。
java.util.concurrent.locks在并发编程中很常用的实用接口。
|----Lock 实现提供了比使用 synchronized 方法和语句可获得的更广泛的锁定操作
|----ReadWriteLock 维护了一对相关的锁,一个用于只读操作,另一个用于写入操作
|----Condition 将 Object 监视器方法(wait、notify 和 notifyAll)分解成截然不同的对象,以便通过将这些对象与任意 Lock 实现组合使用,为每个对象提供多个等待
本篇主要讲解与Lock有关内容,故一下主要针对Lock进行阐述:
接口:
public interface Lock
所有已知实现类:
ReentrantLock
ReentrantReadWriteLock.ReadLock
ReentrantReadWriteLock.WriteLock
随着灵活性的增加,也带来了更多的责任。不使用块结构锁就失去了使用 synchronized 方法和语句时会出现的锁自动释放功能。在大多数情况下,应该使用以下语句:
Lock lk = ...;
lk.lock();
try {
// access the resource protected by this lock
} finally {
lk.unlock();
}
锁定和取消锁定出现在不同作用范围中时,必须谨慎地确保保持锁定时所执行的所有代码用 try-finally 或 try-catch 加以保护,以确保在必要时释放锁。
打印字符串使用锁机制进行打印,使其内部线程之间互斥,源代码如下:
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock; public class LockTest {
public static void main(String[] args) {
final Business business = new Business();
ExecutorService executor = Executors.newFixedThreadPool(3);
for (int i = 0; i < 3; i++) {
executor.execute(
new Runnable() {
public void run() {
business.service();
}
} );
}
executor.shutdown();
} private static class Business {
private int count;
Lock lock = new ReentrantLock(); public void service() {
lock.lock();
try {
count++;
try {
Thread.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(count);
} catch (RuntimeException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
}
}
运行结果如下所示:
提示:更加常用且重要的锁为读写锁,具体详情请查看我的下一篇博客:并发库应用之五 & ReadWriteLock场景应用