JUC

多线程知识点synchronized修饰在成员方法上，其实相当于synchronized(this) { ... }，即锁在当前对象的monitor上。 public synchronized void sync { /* process */ } // 相当于下面 public void sync { synchronized(this) { /* process */ } } 在synchronized方法里，或者synchronized同步代码块中，只要正在执行中，就说明currentThread已经获得当前对象的monitor了。当synchron...

使用线程池jdk默认生成线程池的三大方法Executors.newSingleThreadExecturor(); 创建一个大小为1的线程池Executors.newFixedThreadPool(int x); 创建一个指定大小的线程池Executors.newChacheThreadPoll();创建一个可伸缩的线程池 public class ExecutorServiceTest { public static void main(String[] args) { ExecutorService threadPool1 = Executors.newSingle...

Semaphore 信号量构造方法参数，指定信号量资源的总数acquire方法，获得1个信号量资源，如果信号量满了，需要等待资源释放release方法，释放1个信号量资源，然后通知其他等待的线程常用于多个线程对同一个共享资源的互斥处理，可以做流量限流代码示例：6辆车，3个车位，抢车位 public class SemaphoreTest { public static void main(String[] args) { /** * 6辆车，3个停车位 */ Semaphore semaphore = new Se...

阻塞队列BlockingQueue四组API抛出异常不抛出异常，有返回值阻塞超时等待添加add()offer()put()offer(,,)删除remove()poll()take()poll(,)查看队首元素element()peek() public class BlockingQueueTest { public static void main(String[] args) throws InterruptedException { test4(); } /** * 抛出异常 * add() * remove()...

计划一个缓存类可以向其中put数据（写操作）也可以向其中get数据（读操作） public class ReentrantReadWriteLockTest { public static void main(String[] args) { MyCache myCache = new MyCache(); for (int i = 1; i <= 10; i++) { final int temp = i; new Thread(()-> { myCache...

函数式接口什么是函数式接口？只有一个方法的接口 @FunctionalInterface public interface Runnable { public abstract void run(); } 函数型接口，传入一个值，返回一个值Function接口源码： @FunctionalInterface public interface Function<T, R> { R apply(T t); default <V> Function<V, R> compose(Function<? super V, ? exte...