作者: 秋元_92a3 | 来源:发表于2021-10-20 20:27 被阅读0次

Semaphore

他的作用是控制访问特定资源的线程数目。

# 设置许可线程的数量
public Semaphore(int permits)
# fair表示公平性,如果这个设置为true的话,下次执行的线程会是等待最久的线程 
public Semaphore(int permits, boolean fair)
# 阻塞获取许可
public void acquire() throws InterruptedException
# 释放许可
public void release()

代码实现

public class SemaphoreDemo {

    static class TaskThread extends Thread {

        Semaphore semaphore;

        public TaskThread(Semaphore semaphore) {
            this.semaphore = semaphore;
        }

        @Override
        public void run() {
            try {
                semaphore.acquire();
                System.out.println(getName() + " acquire");
                Thread.sleep(1000);
                semaphore.release();
                System.out.println(getName() + " release ");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    public static void main(String[] args) {
        int threadNum = 5;
        Semaphore semaphore = new Semaphore(2);
        for (int i = 0; i < threadNum; i++) {
            new TaskThread(semaphore).start();
        }
    }

}

主要的应用场景用于限流

ReentrantLock

查看明细

  • java中已经有了内置锁,synchronized,synchronized的特点是使用简单,一切交给jvm去处理。不需要显示释放。
  • 从用法上可以看出,synchronized稍微复杂一点,因为必须在finally中进行解锁,如果不在finally中解锁,有可能代码出现异常锁没被释放。
  • ReentrantLock并不是一种替代内置加锁的方法,而是作为一种可选择的高级功能。
  • 相比于synchronized,reentrantlock在功能上更加丰富,它具有可重入,可中断,可限时、公平锁等特点。
# 可中断
lock.lockInterruptibly();
# 可重入锁
lock.lock();
# 可限时
lock.tryLock(long timeout, TimeUnit unit)
# 公平锁
public ReentrantLock(boolean fair) 

ReentrantReadWriteLock

查看明细

MarriagePhaser

CyclicBarrier

CountDownLatch

AtomicInteger

相关文章

网友评论

      本文标题:

      本文链接:https://www.haomeiwen.com/subject/bjfxaltx.html