小布1994的博客

异步获取有顺序的结果。

CompletableFuture 使用详解

ThreadPoolExecutor创建四种常用线程池package com.xiaobu.util;import com.google.common.util.concurrent.ThreadFactoryBuilder;import lombok.extern.slf4j.Slf4j;import org.apache.commons.lang3.concurrent.BasicThreadFactory;import java.util.concurrent.*;/** * @a

Future和FutureTask的区别Future 是一个接口，无法直接创建对象，需配合线程池使用.submit()方法返回值Future来保存执行结果；而使用.execute()方法传入Runnable接口无返回值FutureTask 是一个类，可以直接创建对象，其实现了RunnableFuture接口（继承Future接口）Future应用package com.xiaobu.juc;import java.util.concurrent.ExecutionException;imp

package Thread;import org.apache.commons.lang3.ArrayUtils;import java.util.ArrayList;import java.util.List;/** * @author xiaobu * @version JDK1.8.0_171 * @date on 2018/10/19 9:13 * @descrp...

package com.xiaobu.base.util;import com.google.common.util.concurrent.ThreadFactoryBuilder;import lombok.extern.slf4j.Slf4j;import java.sql.Connection;import java.sql.PreparedStatement;import java.util.concurrent.*;import java.util.concurrent.atomi

方法一、使用google的ConcurrentHashSet首先引入maven依赖 <dependency> <groupId>com.google.guava</groupId> <artifactId>guava</artifactId> <version>18.0</version> </dependency

synchronized是Java中的关键字，是一种同步锁。它修饰的对象有以下几种：修饰一个代码块，被修饰的代码块称为同步语句块，其作用的范围是大括号{}括起来的代码，作用的对象是调用这个代码块的对象；修饰一个方法，被修饰的方法称为同步方法，其作用的范围是整个方法，作用的对象是调用这个方法的对象；修改一个静态的方法，其作用的范围是整个静态方法，作用的对象是这个类的所有对象；修改一个类，其作用的范围是synchronized后面括号括起来的部分，作用主的对象是这个类的所有对象。一、修饰代码块p

Exchangerpackage com.xiaobu.JUC;import java.util.concurrent.Exchanger;import java.util.concurrent.TimeUnit;/** * @author xiaobu * @version JDK1.8.0_171 * @date on 2019/9/27 16:58 * @descrip...

CountDownLatchCountDownLatch是一个计数器闭锁，通过它可以完成类似于阻塞当前线程的功能，即：一个线程或多个线程一直等待，直到其他线程执行的操作完成。当计数器值减至零时，所有因调用await()方法而处于等待状态的线程就会继续往下执行。这种现象只会出现一次，计数器不能被重置。package com.xiaobu.JUC;import java.util.conc...

package com.demo.Interruput;/** * @author xiaobu * @version JDK1.8.0_171 * @date on 2019/9/25 17:36 * @description 说明：park和wait的区别。wait让线程阻塞前，必须通过synchronized获取同步锁。 */public class WaitTest {...

package com.xiaobu.deadlock;import java.util.concurrent.*;/** * @author xiaobu * @version JDK1.8.0_171 * @date on 2019/8/21 17:16 * @description */public class ExcuteLock { static Exec...

Thread的六个状态：NEW:初始状态，新建了一个线程对象，但是没有执行start方法。RUNNABLE:运行状态，java中将ready(就绪)和running(运行中)统称"运行"BLOCKED:阻塞，表示线程阻塞于锁。WAITING:进入该状态的线程需要等待其他线程做出一些特定动作(比如通知如:notify(),notifyAll()或者中断如:interrupt())TIME...

线程池的简介 继承 实现 继承ThreadPoolExecutor====>AbstractExecutorService=====>>ExecutorService======>>ExecutorExecutors创建线程池的方式singleThr...

JAVA程序检测死锁测试代码package com.xiaobu.learn.deadlock;import java.util.concurrent.LinkedBlockingQueue;import java.util.concurrent.ThreadFactory;import java.util.concurrent.ThreadPoolExecutor;impor...

炒菜问题买菜和买配料先后顺序不一定，但炒菜一定在这两个的后面用CountDownLatch实现package com.xiaobu.learn.concurrent;import com.google.common.util.concurrent.ThreadFactoryBuilder;import java.util.concurrent.*;/** * @author...

一、synchronized作用于实例方法。package Synchronized;/** * @author xiaobu * @version JDK1.8.0_171 * @date on 2019/1/8 16:15 * @description V1.0 synchronized作用于实例方法 同一个对象 */public class Demo1 implem...

一、普通的int型自增长测试package AtomicInteger;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;/** * @author xiaobu * @version JDK1.8.0_171 * @date on 2018/8/7 16:15...

一、Queue一般分为先进先出和后进先出两种先进先出（FIFO）：先插入的队列的元素也最先出队列，类似于排队的功能。从某种程度上来说这种队列也体现了一种公平性。后进先出（LIFO）：后插入队列的元素最先出队列，这种队列优先处理最近发生的事件。如果生产者产出数据的速度大于消费者消费的速度，并且当生产出来的数据累积到一定程度的时候，那么生产者必须暂停等待一下（阻塞生产者线程），以便等...