import java.util.concurrent.SynchronousQueue;public class UseQueue {public static void main(String[] args) throws Exception {/*//高性能無阻塞無界隊(duì)列：ConcurrentLinkedQueueConcurrentLinkedQueue<String> q = new ConcurrentLinkedQueue<String>();q.offer("a");q.offer("b");q.offer("c");q.offer("d");q.add("e");System.out.println(q.poll()); //a 從頭部取出元素，并從隊(duì)列里刪除System.out.println(q.size()); //4System.out.println(q.peek()); //bSystem.out.println(q.size()); //4 */ /*ArrayBlockingQueue<String> array = new ArrayBlockingQueue<String>(6);array.put("a");array.put("b");array.add("c");array.add("d");array.add("e");array.add("f");System.out.println(array.offer("a", 3, TimeUnit.SECONDS));*///阻塞隊(duì)列/*LinkedBlockingQueue<String> q = new LinkedBlockingQueue<String>();q.offer("a");q.offer("b");q.offer("c");q.offer("d");q.offer("e");q.add("f");*/ // System.out.println(q.size());/*for (Iterator iterator = q.iterator(); iterator.hasNext();) {String string = (String) iterator.next();System.out.println(string);}*//*List<String> list = new ArrayList<String>();q.drainTo(list, 3);System.out.println(q.drainTo(list, 3));System.out.println(list.size());for (String string : list) {System.out.println(string);}*/final SynchronousQueue<String> q = new SynchronousQueue<String>();Thread t1 = new Thread(new Runnable() {@Overridepublic void run() {try {System.out.println(q.take());} catch (InterruptedException e) {e.printStackTrace();}}});t1.start();Thread t2 = new Thread(new Runnable() {@Overridepublic void run() {q.add("beijing");}});t2.start(); } } import java.util.concurrent.Delayed; import java.util.concurrent.TimeUnit;public class Wangmin implements Delayed { private String name; //身份證 private String id; //截止時間 private long endTime; //定義時間工具類private TimeUnit timeUnit = TimeUnit.SECONDS;public Wangmin(String name,String id,long endTime){ this.name=name; this.id=id; this.endTime = endTime; } public String getName(){ return this.name; } public String getId(){ return this.id; } /** * 用來判斷是否到了截止時間 */ @Override public long getDelay(TimeUnit unit) { //return unit.convert(endTime, TimeUnit.MILLISECONDS) - unit.convert(System.currentTimeMillis(), TimeUnit.MILLISECONDS);return endTime - System.currentTimeMillis();} /** * 相互批較排序用 */ @Override public int compareTo(Delayed delayed) { Wangmin w = (Wangmin)delayed; return this.getDelay(this.timeUnit) - w.getDelay(this.timeUnit) > 0 ? 1:0; } } import java.util.concurrent.DelayQueue;public class WangBa implements Runnable { private DelayQueue<Wangmin> queue = new DelayQueue<Wangmin>(); public boolean yinye =true; public void shangji(String name,String id,int money){ Wangmin man = new Wangmin(name, id, 1000 * money + System.currentTimeMillis()); System.out.println("網(wǎng)名"+man.getName()+" 身份證"+man.getId()+"交錢"+money+"塊,開始上機(jī)..."); this.queue.add(man); } public void xiaji(Wangmin man){ System.out.println("網(wǎng)名"+man.getName()+" 身份證"+man.getId()+"時間到下機(jī)..."); } @Override public void run() { while(yinye){ try { Wangmin man = queue.take(); xiaji(man); } catch (InterruptedException e) { e.printStackTrace(); } } } public static void main(String args[]){ try{ System.out.println("網(wǎng)吧開始營業(yè)"); WangBa siyu = new WangBa(); Thread shangwang = new Thread(siyu); shangwang.start(); siyu.shangji("路人甲", "123", 1); siyu.shangji("路人乙", "234", 10); siyu.shangji("路人丙", "345", 5); } catch(Exception e){ e.printStackTrace();} } }

?

public class Task implements Comparable<Task>{private int id ;private String name;public int getId() {return id;}public void setId(int id) {this.id = id;}public String getName() {return name;}public void setName(String name) {this.name = name;}@Overridepublic int compareTo(Task task) {return this.id > task.id ? 1 : (this.id < task.id ? -1 : 0); }public String toString(){return this.id + "," + this.name;}}

?

import java.util.concurrent.PriorityBlockingQueue;public class UsePriorityBlockingQueue {public static void main(String[] args) throws Exception{PriorityBlockingQueue<Task> q = new PriorityBlockingQueue<Task>();Task t1 = new Task();t1.setId(3);t1.setName("id為3");Task t2 = new Task();t2.setId(4);t2.setName("id為4");Task t3 = new Task();t3.setId(1);t3.setName("id為1");//return this.id > task.id ? 1 : 0;q.add(t1); //3q.add(t2); //4q.add(t3); //1/*for(Iterator iterator = q.iterator();iterator.hasNext();) {Task task = (Task) iterator.next();System.out.println(task.getName());}*/// 1 3 4 // System.out.println("容器：" + q);System.out.println(q.take().getId());System.out.println("容器：" + q);System.out.println(q.take().getId());System.out.println(q.take().getId());} }

?

總結(jié)

以上是生活随笔為你收集整理的Queue讲解的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。