多線程開發的捷徑：構建Java并發模型框架
14. try {
15. wait();
16. }catch (InterruptedException e) {
17. e.printStackTrace();
18. }
19. }
20.
21. _queue.push(mr);
22. notifyAll();
23. System.out.println("Leave Queue");
24. }
25. public synchronized MethodRequest dequeue() {
26. MethodRequest mr;
27.
28. while(_queue.empty()) {
29. try {
30. wait();
31. }catch (InterruptedException e) {
32. e.printStackTrace();
33. }
34. }
35. mr = (MethodRequest)_queue.pop();
36. notifyAll();
37.
38. return mr;
39. }
40. private Stack _queue;
41. private final static int QUEUE_SIZE = 20;
42.}
43.//ActiveObject的定義
44.class ActiveObject extends Thread
45.{
46. public ActiveObject() {
47. _queue = new ActiveQueue();
48. start();
49. }
50. public void enqueue(MethodRequest mr) {
51. _queue.enqueue(mr);
52. }
53. public void run() {
54. while(true) {
55. MethodRequest mr = _queue.dequeue();
56. mr.call();
57. }
58. }
59. private ActiveQueue _queue;
60.}
通過上面的代碼可以看出正是這些類相互合作完成了對并發邏輯的封裝。開發者只需要根據需要實現MethodRequest接口，另外再定義一個服務代理類提供給使用者，在服務代理者類中把服務調用者的請求轉化為MethodRequest實現，交給活動對象即可。
使用該框架，可以較好的做到應用邏輯和并發模型的分離，從而使開發者集中精力于應用領域，然后平滑的和并發模型結合起來，并且可以針對ActiveQueue定制排隊機制，比如基于優先級等。
基于框架的解決方案
本小節將使用上述的框架重新實現前面的例子，提供對于并發的支持。第一步先完成對于MethodRequest的實現，對于我們的例子來說實現如下：
1.class SayHello implements MethodRequest
2.{
3. public SayHello(Service s) {
4. _service = s;
5. }
6. public void call() {
7. _service.sayHello();
8. }
9. private Service _service;
10.}
該類完成了對于服務提供接口sayHello方法的封裝。接下來定義一個服務代理類，來完成請求的封裝、排隊功能，當然為了做到對Client透明，該類必須實現Service接口。定義如下：
11.class ServiceProxy implements Service
12.{
13. public ServiceProxy() {
14. _service = new ServiceImp();
15. _active_object = new ActiveObject();
16. }
17.
18. public void sayHello() {
19. MethodRequest mr = new SayHello(_service);
20. _active_object.enqueue(mr);
21. }
22. private Service _service;
23. private ActiveObject _active_object;
24.}
其他的類和接口定義不變，下面對比一下并發邏輯增加前后的服務調用的變化，并發邏輯增加前，對于sayHello服務的調用方法：
25.Service s = new ServiceImp();
26.Client c = new Client(s);
27.c.requestService();
并發邏輯增加后，對于sayHello服務的調用方法：
28.Service s = new ServiceProxy();
29.Client c = new Client(s);
30.c.requestService();
可以看出并發邏輯增加前后對于Client的ServiceImp都無需作任何改變，使用方式也非常一致，ServiceImp也能夠獨立的進行重用。類結構圖如下：
