多线程并发的一些常见的使用规范

news2024/11/20 19:19:56

1. 多线程并发使用规范

1.1 指定线程名称

2. 尽量使用线程池

3.不允许使用Executors

4. 正确停止线程

5. 编写可停止的Runnable

6 . Runnable中必须捕获一切异常

7. 可考虑使用ThreadLocal

8. 缩短锁

9. 选择分离锁，分散锁甚至无锁的数据结构

10. 推荐】基于ThreadLocal来避免锁

11. 规避死锁风险

12. volatile修饰符，AtomicXX系列的正确使用

13. 延时初始化的正确写法

1. 多线程并发使用规范

1.1 指定线程名称

【强制】创建线程或线程池时请指定有意义的线程名称，方便出错时回溯。

创建单条线程时直接指定线程名称

      Thread thread = new Thread();
      thread.setName("a");

2. 线程池则使用guava或自行封装的ThreadFactory，指定命名规则。

2. 尽量使用线程池

【推荐】尽量使用线程池来创建线程

除特殊情况，尽量不要自行创建线程，更好的保护线程资源。

同理，定时器也不要使用Timer，而应该使用ScheduledExecutorService。因为Timer只有单线程，不能并发的执行多个在其中定义的任务，而且如果其中一个任务抛出异常，整个Timer也会挂掉，而ScheduledExecutorService只有那个没捕获到异常的任务不再定时执行，其他任务不受影响。

3.不允许使用Executors

【强制】线程池不允许使用Executors去创建，避资源耗尽风险

Executors返回的线程池对象的弊端：

FixedThreadPool和SingleThreadPool:

允许的请求队列长度为Integer.MAX_VALUE，可能会堆积大量的请求，从而导致OOM。

CachedThreadPool和ScheduledThreadPool:

允许的创建线程数量为Integer.MAX_VALUE，可能会创建大量的线程，从而导致OOM。

应通过newThreadPoolExecutor(xxx,xxx,xxx,xxx)这样的方式，更加明确线程池的运行规则，合理设置Queue及线程池的coresize和maxsize，建议使用vjkit封装的ThreadPoolBuilder。

4. 正确停止线程

【强制】正确停止线程

Thread.stop()不推荐使用，强行的退出太不安全，会导致逻辑不完整，操作不原子，已被定义成Deprecate方法。

停止单条线程，执行Thread.interrupt()。

停止线程池：

ExecutorService.shutdown():不允许提交新任务，等待当前任务及队列中的任务全部执行完毕后退出；

ExecutorService.shutdownNow():通过Thread.interrupt()试图停止所有正在执行的线程，并不再处理还在队列中等待的任务。

最优雅的退出方式是先执行shutdown()，再执行shutdownNow()，vjkit的ThreadPoolUtil进行了封装。

注意，Thread.interrupt()并不保证能中断正在运行的线程，需编写可中断退出的Runnable，见规则5。

5. 编写可停止的Runnable

【强制】编写可停止的Runnable

执行Thread.interrupt()时，如果线程处于sleep(),wait(),join(),lock.lockInterruptibly()等blocking状态，会抛出InterruptedException，如果线程未处于上述状态，则将线程状态设为interrupted。

因此，如下的代码无法中断线程:


     public void run(){
         while (true){
            sleep();
         }
      }
      public void sleep(){
         try {
            Thread.sleep(1000);
         } catch (InterruptedException e) {
            throw new RuntimeException(e);
         }
      }

正确处理InterruptException

因为InterruptException异常是个必须处理的CheckedException，所以run()所调用的子函数很容易吃掉异常并简单的处理成打印日志，但这等于停止了中断的传递，外层函数将收不到中断请求，继续原有循环或进入下一个堵塞。

正确处理是调用Thread.currentThread().interrupt();将中断往外传递

  public void sleep(){
         try {
            ....
         } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
         }
      }

主循环及进入阻塞状态前要判断线程状态

6 . Runnable中必须捕获一切异常

【强制】Runnable中必须捕获一切异常

如果Runnable中没有捕获RuntimeException而向外抛出，会发生下列情况：

ScheduledExecutorService执行定时任务，任务会被中断，该任务将不再定时调度，但线程池里的线程还能用于其他任务。
ExecutorService执行任务，当前线程会中断，线程池需要创建新的线程来响应后续任务。
如果没有在ThreadFactory设置自定义的UncaughtExceptionHanlder，则异常最终只打印在System.err，而不会打印在项目的日志中。

因此建议自写的Runnable都要保证捕获异常;如果是第三方的Runnable，可以将其再包裹一层vjkit中的SafeRunnable。