java 多线程并发设计模式之三:Guarded suspension 模式

这是一种是用很多的设计模式, 其核心思想就是服务线程开始就准备好，不断查看是否有新的请求，如果有新的请求，就处理。但事实上，服务端的处理能力很有可能有限，但是作为程序的健壮性，不可能丢掉任何一个客户端请求，这种一个比较好的方案就是对客户端的请求进行排队，放到队列里面，然后服务线程一个一个处理。这样至少能避免服务端处理太多请求而崩溃。

如下例子假设：程序一开始就开启10个服务线程，一直处于等待状态，查看队列中是否有新的请求，如果有就处理。 当服务线程准备好之后，客户端就可以发出请求，这里模拟了10个客户线程，每一个客户线程发起10次请求，中间间隔10毫秒。假设每个服务进程处理一个请求需要100毫秒。明显时间比较长，没办法及时处理客户端请求. 一下代码就是这种模式的核心代码:

服务端线程

package com.yihaomen.gs;
public class ServerThread extends Thread {
    private RequestQueue requestQueue;
    public ServerThread(RequestQueue requestQueue, String name) {
        super(name);
        this.requestQueue = requestQueue;
    }
    public void run() {
    	// 线程一直存在，直到进程结束. 守护线程。
        while (true) {
            final Request request = requestQueue.getRequest();
            try {
				Thread.sleep(100);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
            System.out.println(Thread.currentThread().getName() + " handles  " + request);            
        }
    }
}

package com.yihaomen.gs;
public class ClientThread extends Thread {
    private RequestQueue requestQueue;
    public ClientThread(RequestQueue requestQueue, String name) {
        super(name);
        this.requestQueue = requestQueue;
    }
    public void run() {
    	
        for (int i = 0; i < 10; i++) {
            Request request = new Request("RequestID:" + i+" Thread_Name:"+Thread.currentThread().getName());
            System.out.println(Thread.currentThread().getName() + " requests " + request);
            requestQueue.addRequest(request);
            try {
                Thread.sleep(10);
            } catch (InterruptedException e) {
            }
            System.out.println("ClientThread Name is:"+Thread.currentThread().getName());
        }
    	
        System.out.println(Thread.currentThread().getName()+" request end");
    }
}

package com.yihaomen.gs;

public class Main {
    public static void main(String[] args) {
        RequestQueue requestQueue = new RequestQueue();
        for(int i=0;i<10;i++) {
        	new ServerThread(requestQueue, "ServerThread"+i).start();
        }
        for(int i=0;i<10;i++){
        	new ClientThread(requestQueue, "ClientThread"+i).start();
        }
    }
}