Thread 创建方式
- 继承Thread
- 实现 Runnable 接口
- lanbda 表达式 new Thread(()->}{...}).start; 实际上第二种相同
- 线程池创建
常用方法
sleep
- 睡眠线程
- 不可被主动唤醒 (回到就绪状态)
- 不释放锁
- 仅能操作当前线程
wait
- 休眠线程
- 可被 notify notifyAll 唤醒,唤醒后续重新拿锁 (回到就绪状态)
- 释放锁
- 能操作指定线程对象
- wait只能在同步（synchronize）环境中被调用,非同步直接报错(无法获取到锁)
notify notifyAll
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
// 十个线程(计数器为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);
