**目录**

[TOC]

#### 前言
这篇文章主要用来记录我所收集的一些多线程环境下，java程序员常见的或者说容易忽视的、重要的、容易产生bug的代码样例，以此来加深自己对这些场景代码的印象，让我们一起少掉坑。文章会陆续更新，尽自己能力收集更多的样例。

#### CountDownLatch的错误使用
```java
CountDownLatch countDownLatch = new CountDownLatch(voGroupByBucketName.size());
for (......) {
executorService.submit(() -> {
	try {
		xxxxxxx
		//countDownLatch.countDown();
	} catch (Exception e) {
	...
	} finally {
		countDownLatch.countDown();
	}
	});
}
countDownLatch.await();
```
上面的countDownLatch.countDown();经常有人不写到finally代码块中，造成executorService线程池报错后主线程意外假死，因为程序报错后countDownLatch.countDown()没有被执行，主线程一直await

#### 使用Executors.newCachedThreadPool()创建线程来处理大量任务
```java
ExecutorService executorService = Executors.newCachedThreadPool();
```
由于newCachedThreadPool()创建线程池，如果有任务进入需要拿线程来处理任务，默认会从线程池的缓存中拿，如果没有就会创建新的线程，如果有大量任务需要被执行，那么newCachedThreadPool()的方式就会创建出大量的线程，造成java内存溢出或线程不够用了，所以建议最好还是用固定大小的线程池，这里也给出代码样例，如下：
```java
ThreadFactory factory = new ThreadFactoryBuilder().setNameFormat("task-%d").build();
ExecutorService executorService = new ThreadPoolExecutor(20, 20,0, TimeUnit.SECONDS, 
	new LinkedBlockingQueue<Runnable>(100),factory,new ThreadPoolExecutor.CallerRunsPolicy());
```

####线程池不设置队列大小或者设置很大的队列大小
```java
ThreadFactory factory = new ThreadFactoryBuilder().setNameFormat("task-%d").build();
ExecutorService executorService = new ThreadPoolExecutor(20, 20,0, TimeUnit.SECONDS, 
	new LinkedBlockingQueue<>(),factory,new ThreadPoolExecutor.CallerRunsPolicy());
```
上面的new LinkedBlockingQueue<>()队列没有限制长度，在线程处理不过来的情况下会可能会堆积大量任务数据，造成内存溢出，我们应该设置合理的队列大小，正确的写法参考上一个问题的示例。

#### 使用Future来取线程池返回值时，Future.get()异常后取不到返回值问题
一直以为我都以为Future.get()跟Thread的run()方法一样会自己处理掉异常，然而并不是，这个问题还是很容易就犯错，如下代码：

![](http://img.classinstance.cn/20220707/1657163484155.jpg)

图中122行代码get可能会报错，造成里面的List<UploadPeopleStatus> uploadPeopleStatus赋值不到，于是数据就丢失了，业务的要求应该是报错也要把里面的数据返回，于是要求我们正确的做法应该是线程里面要try catch异常并把数据返回。

#### 多线程共享变量之List.add()与clear()并发原子性问题
我们都知道CopyOnWriteArrayList是线程安全的List实现，所以在并发下执行add()方法是不会有并发问题的，但是如果在并发下又同时执行clear()，这时候就会出现并发问题了，因为这两者同时执行时并不是原子性的，需要我们代码加锁，举个例子，我看到的同事用disruptor来做并发处理业务，在他的EventHandler的方法中，有并发问题的代码如下：
```java
    protected List<VALUE> xxxList = new CopyOnWriteArrayList<>(BATCH_SIZE);
	@Override
    public void onEvent(EVENT event, long sequence, boolean endOfBatch) throws Exception {

VALUE value = getValue(event);
		
        xxxList.add(value);
        if(xxxList.size() == BATCH_SIZE){
            doBatchHandle(xxxList);
            xxxList.clear();
        }

if(endOfBatch && !xxxList.isEmpty()){
            doBatchHandle(xxxList);
            xxxList.clear();
        }
    }
```
其中xxxList.add和xxxList.clear并发执行时就可能出问题了，正确的做法就是代码加锁，如下：
```java
    protected List<VALUE> xxxList = new CopyOnWriteArrayList<>(BATCH_SIZE);
	@Override
    public void onEvent(EVENT event, long sequence, boolean endOfBatch) throws Exception {

VALUE value = getValue(event);
		synchronized (xxxList){
			xxxList.add(value);
			if(xxxList.size() == BATCH_SIZE){
				doBatchHandle(xxxList);
				xxxList.clear();
			}

if(endOfBatch && !xxxList.isEmpty()){
				doBatchHandle(xxxList);
				xxxList.clear();
			}
		}
    }
```

ClassInstance

java程序员多线程常见的代码bug

相关文章

推荐文章

热门文章

标签列表