场景介绍。系统中有一个导入功能,导入后要对数据进行一系列处理。处理逻辑较复杂,所以用一个线程延时来处理。现在的情形就是导入后就创建一组任务,任务加入待处理列表中。处理的线程进行处理,没有任务时就等待,直到有任务进来再唤醒。
现在wait notify都是手工做的,代码乱的没法看了。有经验的筒子们给点建议,有啥现成的Lib啊,模式啊,尽量拍啊

解决方案 »

  1.   

    java.util.concurrent.Executor
    java.util.concurrent.Executors
    java.util.concurrent.ExecutorService
      

  2.   

    把任务添加到 LinkedBlockingQueue 中去,另启一个线程从这个队列中 take 出任务就可以了,没有任务时 take 自己会阻塞掉,如果队列满了,在 put 时就会阻塞掉。看任务的处理速度,以及数量有多少来设定这个 Queue 的长度。
      

  3.   

    LinkedBlockingQueue 属于 Java 集合框架类库之一,并且在 java.util.concurrent 下,其是线程安全的,可以被多个线程并发地进行处理。
      

  4.   

    LinkedBlockingQueue 不错,但是还有点不满足需要
    1,我不希望put进去task之后立刻开始处理,我希望它等我通知的时候在开始
      

  5.   

    导入的数据存在表A中,线程的任务是根据业务逻辑,设置表A中某些字段的值
    导入的方法是有事务控制的。事务控制是由spring的taransaction manager管理的。是加在方法上的。向任务队列中添加任务是在导入方法中做得。导入方法与线程中的操作同时执行的话会报一个数据库异常。所以要在开始导入前,让线程暂停,在结束之后再恢复它