161207高并发：java.util.concurrent.Semaphore实现字符串池及其常用方法介绍

Posted 2020-08-24 目标奔雷手

实现字符串池：
StrPool.java
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Semaphore;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.ReentrantLock;
public class StrPool {
    private int poolMaxSize = 5;//pool的最大值
    private int semaphorePermits = 5;//semaphore的允许数
    private List<String> list = new ArrayList<String>();
    private Semaphore concurrencySemaphore = new Semaphore(semaphorePermits);
    private ReentrantLock lock = new ReentrantLock();
    private Condition condition = lock.newCondition();
    public StrPool() {
        super();
        for (int i = 0; i < poolMaxSize; i++) {
            list.add("字符串" + (i + 1));
        }
    }
    public String get() {
        String getString = null;
        try {
            concurrencySemaphore.acquire();
            lock.lock();
            while (list.size() == 0) {
                condition.await();
            }
            getString = list.remove(0);
            lock.unlock();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return getString;
    }
    public void put(String stringValue) {
        lock.lock();
        list.add(stringValue);
        condition.signalAll();
        lock.unlock();
        concurrencySemaphore.release();
    }
}
TestThread.java
public class TestThread extends Thread {
    private StrPool listPool;
    public TestThread(StrPool listPool) {
        super();
        this.listPool = listPool;
    }
    @Override
    public void run() {
        for (int i = 0; i < Integer.MAX_VALUE; i++) {
            String getStr = listPool.get();
            System.out.println(Thread.currentThread().getName() + " 取到的值："
                    + getStr);
            listPool.put(getStr);
        }
    }
}
Run.java
public class Run {
    public static void main(String[] args) {
        /**
         * 字符串池，实际应用中可以改成数据库连接池等（自己定义）
         */
        StrPool pool = new StrPool();
        TestThread[] threadArray = new TestThread[12];
        for (int i = 0; i < threadArray.length; i++) {
            threadArray[i] = new TestThread(pool);
        }
        for (int i = 0; i < threadArray.length; i++) {
            threadArray[i].start();
        }
    }
}
常用方法：
构造方法：
Semaphore(int permits)  创建具有给定的许可数和非公平的公平设置的 Semaphore。
Semaphore(int permits, boolean fair) 创建具有给定的许可数和给定的公平设置的 Semaphore。
方法：
void acquire() 从此信号量获取一个许可，在提供一个许可前一直将线程阻塞，否则线程被中断。
void acquire(int permits) 从此信号量获取给定数目的许可，在提供这些许可前一直将线程阻塞，或者线程已被中断。
void acquireUninterruptibly() 从此信号量中获取许可，在有可用的许可前将其阻塞。
void acquireUninterruptibly(int permits) 从此信号量获取给定数目的许可，在提供这些许可前一直将线程阻塞。
int availablePermits() 返回此信号量中当前可用的许可数。
int drainPermits() 获取并返回立即可用的所有许可。//一般测试用
protected Collection<Thread>    getQueuedThreads() 返回一个 collection，包含可能等待获取的线程。
int getQueueLength() 返回正在等待获取的线程的估计数目。
boolean hasQueuedThreads() 查询是否有线程正在等待获取。
boolean isFair() 如果此信号量的公平设置为 true，则返回 true。
protected void    reducePermits(int reduction) 根据指定的缩减量减小可用许可的数目。
void release() 释放一个许可，将其返回给信号量。
void release(int permits) 释放给定数目的许可，将其返回到信号量。
String toString() 返回标识此信号量的字符串，以及信号量的状态。
boolean tryAcquire() 仅在调用时此信号量存在一个可用许可，才从信号量获取许可。
boolean tryAcquire(int permits) 仅在调用时此信号量中有给定数目的许可时，才从此信号量中获取这些许可。
boolean tryAcquire(int permits, long timeout, TimeUnit unit) 如果在给定的等待时间内此信号量有可用的所有许可，并且当前线程未被中断，则从此信号量获取给定数目的许可。
boolean tryAcquire(long timeout, TimeUnit unit) 如果在给定的等待时间内，此信号量有可用的许可并且当前线程未被中断，则从此信号量获取一个许可。