手写Lock public class SpinLockDemo { AtomicReference<Thread> atomicReference = new AtomicReference<>(); public void MyLock() { Thre

Administrator发布于 November 22,2023

CAS 操作 与 ABA问题 compareAndSet 函数交CAS操作 AtomicInteger atomicInteger = new AtomicInteger(); atomicInteger.compareAndSet(0,2); public final boolean compa

Administrator发布于 November 22,2023

异步回调 CompletableFuture future = CompletableFuture.runAsync(()-> { System.out.println(55555); }); future.handle((o,t)-> { System.out.println(o)

Administrator发布于 November 22,2023

ForkJoinTask public class ForkJoinDemo extends RecursiveTask<Long> { long tem = 20000; long start = 0; long end = 10_000_000; public

Administrator发布于 November 22,2023

public class StreamDemo { public static void main(String[] args) { List<Student> list = new ArrayList<>(); list.add(new Student("C

Administrator发布于 November 22,2023

public class BlockQueueDemo { public static void main(String[] args) throws InterruptedException { //addRemoveTest(); offerPollDemo();

Administrator发布于 November 22,2023

读写锁 使用 public class ReadWriteLockDemo { public static void main(String[] args) { MapCatch mapCatch = new MapCatch(); for (int i =

Administrator发布于 November 22,2023

CountDownLatch，CyclicBarrier，Semaphore CountDownLatch 的await可以阻塞一个线程，等待全部countdown完毕，则跳过wait CyclicBarrier 阻塞多个线程，执行完毕后返回自身runnable Semaphore 信号量通过信号量

Administrator发布于 November 22,2023

Callable callable拥有返回值得runnable，可以通过FutureTask来进行包装 public class CallableDemo { public static void main(String[] args) throws ExecutionException,

Administrator发布于 November 22,2023

队列安全操作 我们都知道 Arraylist，add操作时不安全的，没有加锁 1.使用 Vector，里面的操作是加了锁的 2.使用Collections.synchronizedList() ，他里面的操作也是加了锁的，类似装饰者，给需要同步的操作加锁，迭代器没有做同步，Vector的迭代器做了同

Administrator发布于 November 22,2023