_producerListeners 应该调整下结构

[xinzhuxiansheng]

private ConcurrentHashMap<String, Runnable> _producerListeners ,
假设，现在用户使用sdk 并且利用多线程，创建producer ，那么对于_producerListeners，就会出现，覆盖 ，可以利用 ConcurrentHashMap<String, List> 定义 _producerListeners

[koqizhao]

是的，这是考虑步骤的地方，会进行调整改进。