多线程与原子类问题,遇到了线程中断,记录一下
多线程和原子类多看看源码
Executors.newFixedThreadPool底层调用了ThreadPoolExecutor的方法,所以使用ThreadPoolExecutor对象
AtomicInteger保证了内存可见性和原子操作性,只是输出会乱序,但是值没问题
AtomicInteger 是乐观锁CAS,一个锁+循环获取锁,但是会产生ABA问题,有兴趣可以了解一下,加上一个时间戳判定即可解决问题。
ReentrantLock也是一个可重入的互斥锁,ReentrantLock分为“公平锁”和“非公平锁”。ReentraantLock是通过一个FIFO的等待队列来管理获取该锁所有线程的。
在“公平锁”的机制下,线程依次排队获取锁;而“非公平锁”在锁是可获取状态时,不管自己是不是在队列的开头都会获取锁。
在使用完多线程的最后的最后,要将线程池关闭,不要等待超时关闭。
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class AtomicThread {
private static final ThreadPoolExecutor service= (ThreadPoolExecutor) Executors.newFixedThreadPool(50);
private static volatile AtomicInteger atomicInteger=new AtomicInteger(0);
public static void main(String[] args) {
int i=0;
final Lock lock=new ReentrantLock();
while(i<=50000){
service.execute(new Runnable() {
@Override
public void run() {
try {
lock.lock();
/**
* 原子类已经保证了内存可见性和操作原子性
* 但是在下面两句执行的过程中有可能发生线程中断
* 导致打印出重复值或者缺失
* 将两句语句上锁,就没问题了
*/
System.out.println("ai=" + atomicInteger.get());
atomicInteger.incrementAndGet();
lock.unlock();
} catch (Exception e) {
}
}
});
i++;
System.out.println("i="+i);
}
System.out.println("执行结束");
service.shutdown();
}
}