LockSupport和AbstractQueuedSynchronizer是Java并发编程中的两个重要类。
LockSupport是一个线程阻塞工具类,可以用来实现线程的挂起和唤醒操作。它通过让线程获取或释放许可证来实现线程的阻塞和唤醒。LockSupport类提供了park()和unpark()方法来实现线程的阻塞和唤醒操作。
一个实际的例子是使用LockSupport实现线程的暂停和恢复。下面是一个简单的示例代码:
import java.util.concurrent.locks.LockSupport;
public class ThreadPauseResumeExample {
public static void main(String[] args) {
Thread thread = new Thread(() -> {
System.out.println("Thread started");
// 暂停线程
LockSupport.park();
System.out.println("Thread resumed");
});
thread.start();
// 主线程休眠1秒钟
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
// 恢复线程
LockSupport.unpark(thread);
}
}
在上面的例子中,我们创建了一个新的线程,并在该线程中使用LockSupport.park()方法暂停线程。然后,主线程休眠1秒钟后,使用LockSupport.unpark()方法恢复线程的执行。
AbstractQueuedSynchronizer(简称AQS)是一个用于构建锁和同步器的框架类。它提供了一种基于FIFO等待队列的同步机制,可以用来实现独占锁和共享锁等各种同步器。
一个实际的例子是使用AbstractQueuedSynchronizer实现一个简单的独占锁。下面是一个简单的示例代码:
import java.util.concurrent.locks.AbstractQueuedSynchronizer;
public class SimpleExclusiveLock {
private static class Sync extends AbstractQueuedSynchronizer {
@Override
protected boolean tryAcquire(int arg) {
if (compareAndSetState(0, 1)) {
setExclusiveOwnerThread(Thread.currentThread());
return true;
}
return false;
}
@Override
protected boolean tryRelease(int arg) {
if (getState() == 0) {
throw new IllegalMonitorStateException();
}
setExclusiveOwnerThread(null);
setState(0);
return true;
}
@Override
protected boolean isHeldExclusively() {
return getState() == 1;
}
}
private final Sync sync = new Sync();
public void lock() {
sync.acquire(1);
}
public void unlock() {
sync.release(1);
}
public boolean isLocked() {
return sync.isHeldExclusively();
}
}
在上面的例子中,我们通过继承AbstractQueuedSynchronizer类并重写其中的方法来实现一个简单的独占锁。通过调用acquire()方法获取锁,调用release()方法释放锁,调用isHeldExclusively()方法判断锁是否被当前线程持有。
这些是LockSupport和AbstractQueuedSynchronizer的两个实际例子。它们在Java并发编程中扮演着重要的角色,可以用于实现线程的挂起和唤醒以及构建各种同步器。
领取专属 10元无门槛券
手把手带您无忧上云