Go语言视频零基础入门到精通

痴迷编程

elayQueue

是一个无界的BlockingQueue，用于放置实现了Delayed接口的对象，其中的对象只能在其到期时才能从队列中取走。这种队列是有序的，即队头对象的延迟到期时间最长。注意：不能将null元素放置到这种队列中。



Delayed


一种混合风格的接口，用来标记那些应该在给定延迟时间之后执行的对象。

此接口的实现必须定义一个 compareTo 方法，该方法提供与此接口的 getDelay 方法一致的排序。



下面的代码模拟一个考试的日子，考试时间为120分钟，30分钟后才可交卷，当时间到了，或学生都交完卷了者考试结束。线程的关闭参考java编程思想中例子，将exec传给Student的一个内部类，通过他来关闭。

2. package com.woxiaoe.study.thread;  
3.   
4. import java.util.Random;  
5. import java.util.concurrent.DelayQueue;  
6. import java.util.concurrent.Delayed;  
7. import java.util.concurrent.ExecutorService;  
8. import java.util.concurrent.Executors;  
9. import java.util.concurrent.TimeUnit;  
10.   
11. /**
12. * 模拟考试，时间为120分钟，学生可以再30分钟后交卷，
13. * 当学生都交完了 或 时间到者考试结束
14. * @author 小e
15. *
16. * 2010-4-30 下午11:14:25
17. */  
18. class Student implements Runnable,Delayed{  
19.     private String name;  
20.     private long submitTime;//交卷时间  
21.     private long workTime;//考试时间  
22.     public Student() {  
23.         // TODO Auto-generated constructor stub  
24.     }  
25.     public Student(String name, long submitTime) {  
26.         super();  
27.         this.name = name;  
28.         workTime = submitTime;  
29.         //都转为转为ns  
30.         this.submitTime = TimeUnit.NANOSECONDS.convert(submitTime, TimeUnit.MILLISECONDS) + System.nanoTime();  
31.     }  
32.   
33.     @Override  
34.     public void run() {  
35.         System.out.println(name + " 交卷,用时" + workTime/100 + "分钟");  
36.     }  
37.   
38.     @Override  
39.     public long getDelay(TimeUnit unit) {  
40.         return unit.convert(submitTime - System.nanoTime(), unit.NANOSECONDS);  
41.     }  
42.   
43.     @Override  
44.     public int compareTo(Delayed o) {  
45.         Student that = (Student) o;  
46.         return submitTime > that.submitTime?1:(submitTime < that.submitTime ? -1 : 0);  
47.     }  
48.     public static class EndExam extends Student{  
49.         private ExecutorService exec;  
50.         public EndExam(int submitTime,ExecutorService exec) {  
51.             super(null,submitTime);  
52.             this.exec = exec;  
53.         }  
54.         @Override  
55.         public void run() {  
56.             exec.shutdownNow();  
57.         }  
58.     }  
59.       
60. }  
61. class Teacher implements Runnable{  
62.     private DelayQueue<Student> students;  
63.     private ExecutorService exec;  
64.       
65.     public Teacher(DelayQueue<Student> students,ExecutorService exec) {  
66.         super();  
67.         this.students = students;  
68.         this.exec = exec;  
69.     }  
70.   
71.   
72.     @Override  
73.     public void run() {  
74.         try {  
75.             System.out.println("考试开始……");  
76.             while (!Thread.interrupted()) {  
77.                 students.take().run();  
78.             }  
79.             System.out.println("考试结束……");  
80.         } catch (InterruptedException e) {  
81.             e.printStackTrace();  
82.         }  
83.   
84.     }  
85.       
86. }  
87. public class Exam {  
88.     static final int STUDENT_SIZE = 45;  
89.     public static void main(String[] args) {  
90.         Random r = new Random();  
91.         DelayQueue<Student> students = new DelayQueue<Student>();  
92.         ExecutorService exec = Executors.newCachedThreadPool();  
93.         for(int i = 0; i < STUDENT_SIZE; i++){  
94.             students.put(new Student("学生" + ( i + 1), 3000 + r.nextInt(9000)));  
95.         }  
96.         students.put(new Student.EndExam(12000,exec));//1200为考试结束时间  
97.         exec.execute(new Teacher(students, exec));  
98.          
99.     }  
100.   
101. }  

复制代码

考试开始……学生19 交卷,用时35分钟学生16 交卷,用时40分钟学生7 交卷,用时42分钟学生14 交卷,用时52分钟学生15 交卷,用时54分钟学生1 交卷,用时57分钟学生11 交卷,用时62分钟学生2 交卷,用时71分钟学生13 交卷,用时73分钟学生3 交卷,用时78分钟学生20 交卷,用时85分钟学生17 交卷,用时85分钟学生18 交卷,用时90分钟学生6 交卷,用时94分钟学生9 交卷,用时97分钟学生8 交卷,用时102分钟学生12 交卷,用时103分钟学生5 交卷,用时104分钟学生10 交卷,用时108分钟学生4 交卷,用时112分钟考试结束