使用场景:
开启一个任务线程专门处理 日志任务,
//任务队列
protected static BlockingQueue queue = new LinkedBlockingQueue();
//独立线程处理任务
static {
new Thread(){
@Override
public void run() {
try {
while (true){
Object take = queue.take();
System.out.println(take);
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}.start();
}
在redkale 中的使用
个人博客地址:http://1216.top 码云/GitHub:https://gitee.com/tc608