serverthread.java

java多线程设计模式中的guarded suspension模式源码

package guardedsuspension.sample;
import java.util.Random;

public class ServerThread extends Thread {
    private Random random;
    private RequestQueue requestQueue;
	private boolean stopped = false;
    public ServerThread(RequestQueue requestQueue, String name, long seed) {
        super(name);
        this.requestQueue = requestQueue;
        this.random = new Random(seed);
    }
	public void Stop(){
	  this.stopped = true;
      Thread.currentThread().interrupt();
	}
    public void run() {

        for (int i = 0; i < 20; i++) {
            Request request = requestQueue.getRequest();
            System.out.println(Thread.currentThread().getName() + " handles  " + request);
            try {
                Thread.sleep(random.nextInt(1000));
            } catch (InterruptedException e) {
            }
        }
		System.out.println(Thread.currentThread().getName() + " exited. ");
    }
}