Thread

Thread 创建方式

• 继承Thread
• 实现 Runnable 接口
• lanbda 表达式 new Thread(()->}{...}).start; 实际上第二种相同
• 线程池创建

常用方法

sleep

• 睡眠线程
• 不可被主动唤醒 (回到就绪状态)
• 不释放锁
• 仅能操作当前线程

wait

• 休眠线程
• 可被 notify notifyAll 唤醒,唤醒后续重新拿锁 (回到就绪状态)
• 释放锁
• 能操作指定线程对象
• wait只能在同步（synchronize）环境中被调用,非同步直接报错(无法获取到锁)

notify notifyAll

• 唤醒 被wait的线程

yield

• 使线程返回到就绪状态
• 一定会退出cpu一次
• 不保证当前的线程会暂停
• 退出cpu会从队列中根据优先级重新执行某线程

join

• 加入其他线程中执行
• 指定当前线程是无效
• 从执行出(t2.join())阻塞,直到t2线程结束

interrupt

• 对于正常线程来说,只是改变中断状态,即Thread.isInterrupted()返回true
• 对于阻塞线程来说(wait,join,sleep),将抛出InterruptedException

getState

• 获取线程状态

Thread 状态

• New : 刚new 出来 未被start
• Ready: 就绪状态
• Running: 被cpu执行
• TimedWaiting: 指定时间等待
• Waiting: 等待
• Blocked: 阻塞 拿锁
• Teminated: 终止

常用工具类

CountDownLatch

• 判断N个线程是否全部执行完
• 阻塞

// 十个线程(计数器为10)
CountDownLatch latch=new CountDownLatch(10);
//计数器-1
latch.countDown(); 
//阻塞 当计数器为0是继续执行
latch.await(); 

CyclicBarrier

• 攒够一定线程后批量执行
• 阻塞

//攒多少个线程,攒够后执行的方法
CyclicBarrier barriar = new CyclicBarrier(10,new Runnable(){  
    @Override
    public void run(){
        System.out.println("攒够了");
    }
})
 //阻塞 攒够指定线程数量后批量执
barriar.await();

Phaser

• 攒够线程后执行 分段
• 阻塞

Phaser phaser = new  Phaser();
//注册线程数量
phaser.bulkRegister(7); 
//到达栅栏,等待继续往前走
phaser.arriveAndAwaitAdvance();
// 到达栅栏,不注册,后续步骤与该线程无关
phaser.arriveAndDeregister();
@Override
//满足栅栏条件后自动执行  当前在第几步  此阶段
public boolean onAdvance(int phase,int registeredParties){参加线程
    switch(phase){
        case 0:
            //继续执行
            return false; 
        default:
            //不继续执行
            return true; 
    } 
}

Semaphore

• 可用于限流
• 可公平
• 队列

//允许同时进行多少个线程 是否公平
Semaphore s = new Semaphore(1,true);
// 允许数-1 ,当前为0 则进入队列
s.acquire();
//允许数+1
s.releas();

Exchanger

• 线程通信
• 用于两个线程交换数据
• 阻塞

Exchanger<T> ex=new Exchanger<>();
//阻塞,内部有两个位置 将两个线程的值交换返回(有两个值时继续执行)
t=ex.exchange(t); 

LockSupport

• 阻塞当前线程
• 解锁指定线程
• wait()必须借助锁 而 LockSupport 不需要

LockSupport.park();
LockSupport.unPark(t);