clientthread.java

来自「java多线程设计模式中的guarded suspension模式源码」· Java 代码 · 共 27 行

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

public class ClientThread extends Thread {
    private Random random;
    private RequestQueue requestQueue;
    public ClientThread(RequestQueue requestQueue, String name, long seed) {
        super(name);
        this.requestQueue = requestQueue;//请求队列
        this.random = new Random(seed);
    }
    public void run() {
        for (int i = 0; i < 20; i++) {
            Request request = new Request("No." + i);
            System.out.println(Thread.currentThread().getName() + " requests " + request);

            requestQueue.putRequest(request);

            try {
                Thread.sleep(random.nextInt(1000));
            } catch (InterruptedException e) {
            }
        }
      System.out.println(Thread.currentThread().getName() + " exited. ");
    }
}