多线程#

1.1并发和并行【理解】#

• 并行：在同一时刻，有多个指令在多个CPU上同时执行。

• 并发：在同一时刻，有多个指令在单个CPU上交替执行。

1.2进程和线程【理解】#

• 进程：是正在运行的程序独立性：进程是一个能独立运行的基本单位，同时也是系统分配资源和调度的独立单位动态性：进程的实质是程序的一次执行过程，进程是动态产生，动态消亡的并发性：任何进程都可以同其他进程一起并发执行

• 线程：是进程中的单个顺序控制流，是一条执行路径​ 单线程：一个进程如果只有一条执行路径，则称为单线程程序​ 多线程：一个进程如果有多条执行路径，则称为多线程程序​ 

1.3实现多线程方式一：继承Thread类#

• 实现步骤

  • 定义一个类MyThread继承Thread类
  • 在MyThread类中重写run方法
  • 创建MyThread类的对象
  • 启动线程

1.4实现多线程方式二：实现Runnable接口#

• 实现步骤

  • 定义一个类MyRunnable实现Runnable接口
  • 在MyRunnable类中重写run方法
  • 创建MyRunnable类的对象
  • 创建Thread类的对象，把MyRunnable对象作为构造方法的参数
  • 启动线程

1.5实现多线程方式三: 实现Callable接口#

• 实现步骤

  • 定义一个类MyCallable实现Callable接口
  • 在MyCallable类中重写call()方法
  • 创建MyCallable类的对象
  • 创建Future的实现类FutureTask对象，把MyCallable对象作为构造方法的参数
  • 创建Thread类的对象，把FutureTask对象作为构造方法的参数
  • 启动线程
  • 再调用get方法，就可以获取线程结束之后的结果。

• 三种实现方式的对比

  • 实现Runnable、Callable接口
    • 好处: 扩展性强，实现该接口的同时还可以继承其他的类
    • 缺点: 编程相对复杂，不能直接使用Thread类中的方法
  • 继承Thread类
    • 好处: 编程比较简单，可以直接使用Thread类中的方法
    • 缺点: 可以扩展性较差，不能再继承其他的类

1.6线程优先级（概率）#

• getPriority() 返回此线程的优先级

• setPriority() 更改此线程的优先级线程默认优先级是5；线程优先级的范围是：1(MIN)-10(MAX)

• yield() 把线程让出来 重新抢

• join() 把这个线程先执行

1.7守护线程 (备胎线程)#

setDaemon(boolean on) 将此线程标记为守护线程，当运行的线程都是守护线程时，Java虚拟机将陆续退出

2.1同步代码块#

把多条语句操作共享数据的代码给锁起来，让任意时刻只能有一个线程执行即可

1
synchronized(任意对象) {
2
    多条语句操作共享数据的代码
3
}

2.2同步方法#

默认锁为类名.class

1
修饰符 synchronized 返回值类型 方法名(方法参数) {
2
    方法体；
3
}

4.1消费者生产者代码 wait() notify()#

4.2.阻塞队列实现#

ArrayBlockingQueue put() take()

LinkedBlockingQueue

6.1 线程池-Executors默认线程池#

在真实企业开发中我们也很少去自定义线程池，而是使用JDK中自带的线程池，我们可以使用Executors中所提供的静态方法来创建线程池

• ​static ExecutorService newCachedThreadPool() 创建一个默认的线程池

• static newFixedThreadPool(int nThreads) 创建一个指定最多线程数量的线程池

然后提交任务 submit( new MyRunnable () or new MyCallable() )

最后可以销毁线程池 shutdown();

6.2 自定义线程池-ThreadPoolExecutor#

1
    public ThreadPoolExecutor(int corePoolSize,
2
                                  int maximumPoolSize,
3
                                  long keepAliveTime,
4
                                  TimeUnit unit,
5
                                  BlockingQueue<Runnable> workQueue,
6
                                  ThreadFactory threadFactory,
7
                                  RejectedExecutionHandler handler)
8
    corePoolSize：   核心线程的最大值，不能小于0
9
    maximumPoolSize：最大线程数，不能小于等于0，maximumPoolSize >= corePoolSize
10
    keepAliveTime：  空闲线程最大存活时间,不能小于0
11
    unit：           时间单位
12
    workQueue：      任务队列，不能为null
13
    threadFactory：  创建线程工厂,不能为null
14
    handler：        任务的拒绝策略,不能为null