1、Java并发编程入门与高并发面试-课程导学

慕课网 Jimin老师 Java并发编程入门与高并发面试 学习笔记
Java并发编程入门与高并发面试

包括：

线程安全、线程封闭、线程调度、同步容器、并发容器、AQS、J.U.C

解决思路：

扩容、缓存、队列、拆分、服务降级与熔断、数据库切库、分表分库、等等

image.png

并发及并发的线程安全处理

image.png

1. 线程安全性
   原子性、可见性、有序性、atomic包、CAS算法、synchorized与Lock、volatile、happes-before
2. 安全发布对象
   安全发布方法、不可变对象、final关键字使用、不可变方法、线程不安全类与写法
3. 线程安全手段
   堆栈封闭、ThreadLocal线程封闭、JDBC的线程封闭、同步容器、并发容器、J.U.C
4. AQS及其他J.U.C组件
   CountDownLatch. Semaphore.CyclicBarier. ReentrantLock与锁、Condition, FutureTask、ForkJoin框架、BlockingQueue
5. 线程池
   new Thread弊端、线程池的好处、ThreadPoolExecutor.Executor框架接口
6. 额外补充
   死锁的产生与预防、多线程并发最佳实践、Spring 的线程安全、HashMap和ConcurrentHashMap深入讲解

200线程同时执行时候,count只有4890，如果threadTotal 改成1，则是5000，就是线下测试时候一直都是对的，放到线上并发大了，就老是会出问题！

@Slf4j
public class MapExample {
    //200个线程同时执行
    private static int threadTotal = 200;
    private static int clientTotal = 5000;

    private static Map<Integer, Integer> map = Maps.newHashMap();

    public static void main(String[] args) {
        ExecutorService exec = Executors.newCachedThreadPool();
        final Semaphore semaphore = new Semaphore(threadTotal);
        for (int index = 0; index < clientTotal; index++) {
            final int threadNum = index;
            exec.execute(() -> {
                try {
                    semaphore.acquire();
                    func(threadNum);
                    semaphore.release();
                } catch (InterruptedException e) {
                    log.error("exception", e);
                    e.printStackTrace();
                }
            });
        }
        exec.shutdown();
        log.error("count:{}", map.size());//count:4890
    }

    private static void func(int threadNum) {
        map.put(threadNum, threadNum);
    }
}

import lombok.extern.slf4j.Slf4j;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;

@Slf4j
public class CountExample {
    private static int threadTotal = 200;
    private static int clientTotal = 5000;
    private static long count = 0;

    public static void main(String[] args) {
        ExecutorService exec = Executors.newCachedThreadPool();
        final Semaphore semaphore = new Semaphore(threadTotal);
        for (int index = 0; index < clientTotal; index++) {
            exec.execute(() -> {
                try {
                    semaphore.acquire();
                    add();
                    semaphore.release();
                } catch (InterruptedException e) {
                    log.error("exception", e);
                    e.printStackTrace();
                }
            });
        }
        exec.shutdown();
        log.error("count:{}", count);//count:4911
    }

    private static void add() {
        count++;
    }
}

并发基本概念

并发:同时拥有两个或者多个线程，如果程序在单核处理器上运行多个线程将交替地换入或者换出内存，这些线程是同时"存在"的,每个线程都处于执行过程中的某个状态如果运行在多核处理器上,此时,程序中的每个线程都将分配到一个处理器核上,因此可以同时运行.

高并发:

高并发( High Concurrency )是互联网分布式系统架构设计中必须考虑的因素之一 ,它通常是指,通过设计保证系统能够同时并行处理很多请求.

image.png

高并发处理的思路及手段

1、扩容：水平扩容、垂直扩容的探讨
2、缓存：Redis. Memcache、 Guava Cache等的介绍与使用
3、队列：Kafka、RabbitMQ、RocketMQ等队列特性介绍及使用队列的关注点
4、应用拆分：服务化Dubbo与微服务Spring Cloud介绍
5、限流：Guava Ratel imiter的介绍与使用、常用限流算法、自己实现分布式限流等
6、服务降级与服务熔断：服务降级的多种选择、Hystrix介绍及使用等
7、数据库切库、分库、分表：介绍切库、分表、支持多数据源的原理及实现
8、高可用的一些手段：任务调度分布式elastic-job.主备curator的实现、监控报，警机制等

image.png