线程声明
- implements Runable -> run
public class myRunable implements Runnable{
@Override
public void run() {
// TODO do some thread things
}
}
- implements Callable -> call
有返回值,通过FutureTask封装后注入Thread中执行,可异步获取执行结果
public class myCallable implements Callable<Integer>{
@Override
public Integer call() throws Exception {
// TODO do some thread things
return null;
}
}
- extends Thread -> run
线程池Excutor
- cachedThreadPool
一个任务创建一个线程
- fixedThreadPool
固定线程数量
- singleThreadPool
固定1个线程
线程调度操作方法
- sleep()
阻塞线程,继续持有锁和资源,设置时间后会自动继续、
- wait()
阻塞线程,放弃锁和资源进入等待唤醒队列
- notify()
通知唤醒队列内某个线程挂起
- notifyAll()
通知唤醒队列内所有线程挂机,准备竞争锁
- yield()
降权
- join()
阻塞线程,当前线程阻塞,执行join线程内容,join线程执行结束继续执行当前线程
- deamon
非主线程
- condition
依赖Lock,使用Lock时,方法wait,signal,signalAll代替OBJ的wait,notify,notifyAll
协作,通信,锁
- 通信
- 阻塞同步
假如A和B同时竞争对象O锁,A先获取了锁- synchronized
对象B会一直等待A释放锁,适合竞争不是很多的情况,且java自身会对sync优化。依赖于JVM实现
- ReentrantLock(lock)
对象B会等待一定时间后,中断等待干其他事情,适合竞争多的情况,同步操作有更多的操作方法。JDK实现,自旋锁实现,使用了CAS
a) lock(), 如果获取了锁立即返回,如果别的线程持有锁,当前线程则一直处于休眠状态,直到获取锁
b) tryLock(), 如果获取了锁立即返回true,如果别的线程正持有锁,立即返回false;
c)tryLock(long timeout,TimeUnit unit), 如果获取了锁定立即返回true,如果别的线程正持有锁,会等待参数给定的时间,在等待的过程中,如果获取了锁定,就返回true,如果等待超时,返回false;
d) lockInterruptibly:如果获取了锁定立即返回,如果没有获取锁定,当前线程处于休眠状态,直到或者锁定,或者当前线程被别的线程中断
锁
- 自旋
由于锁的操作需要用户态-核心态的转换消耗,对于锁控制时间短的,下一个线程自己等待一下锁释放,就减少了状态转换消耗
- 乐观 CAS
- 偏向
第一次执行CAS,然后给该线程标记,以后若没有竞争则该线程一直将锁消除
- 死锁
死锁产生的四个必要条件
互斥条件:资源是独占的且排他使用,进程互斥使用资源,即任意时刻一个资源只能给一个进程使用,其他进程若申请一个资源,而该资源被另一进程占有时,则申请者等待直到资源被占有者释放。
不可剥夺条件:进程所获得的资源在未使用完毕之前,不被其他进程强行剥夺,而只能由获得该资源的进程资源释放。
请求和保持条件:进程每次申请它所需要的一部分资源,在申请新的资源的同时,继续占用已分配到的资源。
循环等待条件:在发生死锁时必然存在一个进程等待队列{P1,P2,…,Pn},其中P1等待P2占有的资源,P2等待P3占有的资源,…,Pn等待P1占有的资源,形成一个进程等待环路,环路中每一个进程所占有的资源同时被另一个申请,也就是前一个进程占有后一个进程所深情地资源。
解决死锁
一是死锁预防,就是不让上面的四个条件同时成立。
二是,合理分配资源。
三是使用银行家算法,如果该进程请求的资源操作系统剩余量可以满足,那么就分配
AtomicXXXX
CAS操作完成原子性
CopyOnWriteXXX
先复制一份副本,在副本中进行操作,其ADD是经过lock锁的,操作完成,将原地址指向改为副本地址指向,完成对数组的安全操作。内存消耗高,实时性低。复制的目的是进行读写分离,写操作不影响原数据读。读不加锁。适合读多写少的需求。