线程声明
- 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锁的，操作完成，将原地址指向改为副本地址指向，完成对数组的安全操作。内存消耗高，实时性低。复制的目的是进行读写分离，写操作不影响原数据读。读不加锁。适合读多写少的需求。
网友评论