大家好，又见面了，我是你们的朋友全栈君。
package main.com.lift;
import com.google.common.collect.Lists;
import java.util.List;
import java.util.Queue;
import java.util.concurrent.Callable;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.LinkedBlockingQueue;
public class Task implements Callable<Queue<Integer>> {
List<Integer> loucengList;
CyclicBarrier cyclicBarrier;
LinkedBlockingQueue<Integer> queue;
public Task(CyclicBarrier cyclicBarrier,List<Integer> loucengList,LinkedBlockingQueue<Integer> queue){
this.cyclicBarrier=cyclicBarrier;
this.loucengList=loucengList;
this.queue=queue;
}
@Override
public Queue<Integer> call() throws Exception {
Queue<Integer> childQueue= Lists.newLinkedList();
try{
cyclicBarrier.await();
do{
synchronized (queue){
if(queue.size()>0){
int a=queue.poll();
if(loucengList.toString().contains(a+"")){
childQueue.offer(a);
}else {
queue.offer(a);
}
}
}
System.out.println(","+queue.size());
}while (queue.size()>0);
}catch (Exception e){
e.printStackTrace();
}
return childQueue;
}
}
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
发布者：全栈程序员-站长，转载请注明出处：https://javaforall.net/105943.html原文链接：https://javaforall.net
