多线程环境下使用 RocketMQ 遇到的一个问题

[ClancyH]

主线程中通过 DefaultMQPushConsumer 获取数据队列的数据存到一个非堵塞队列中，然后另外一个线程 poll 数据处理，但是运行后发现处理线程处理几条数据之后，一直只有获取数据没有执行数据了。

[Malthael]

贴代码

[ClancyH]

发现问题原因了，应该是处理程序挂在通过 Druid 获取数据库连接上了，对应的线程信息

"Thread-0" #10 prio=5 os_prio=0 tid=0x00007fd8d4491000 nid=0x3d0e waiting on condition [0x00007fd89f7e1000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for <0x00000000d950b8e0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
at com.alibaba.druid.pool.DruidDataSource.takeLast(DruidDataSource.java:1899)
at com.alibaba.druid.pool.DruidDataSource.getConnectionInternal(DruidDataSource.java:1460)
at com.alibaba.druid.pool.DruidDataSource.getConnectionDirect(DruidDataSource.java:1255)
at com.alibaba.druid.pool.DruidDataSource.getConnection(DruidDataSource.java:1235)
at com.alibaba.druid.pool.DruidDataSource.getConnection(DruidDataSource.java:1225)
at com.zzx.wwl.alarm.util.DataBaseUtil.getConnection(DataBaseUtil.java:32)
at com.zzx.wwl.alarm.Start$1.run(Start.java:41)
at java.lang.Thread.run(Thread.java:748)