보호 일시 중단 모드(Guarded Suspension)

17865 단어 다중 스레드
핵심 사상은 만약에 특정한 라인이 특정한 조작을 실행하기 전에 일정한 조건을 충족시켜야 한다면 이 조건이 충족되지 않을 때 라인의 운행을 일시 정지한다(즉 라인을 잠정적으로 끄고 대기(waiting) 상태로 이 조건이 충족될 때까지 계속 운행한다)
public class Requets
{
     
    final private String value;

    public Requets(String value) {
     
        this.value = value;
    }

    public String getValue() {
     
        return value;
    }
}

대기열 만들기
public class RequestQueue {
     

    private final LinkedList<Requets> queue = new LinkedList<>();

    public Requets getRequest(){
     
        synchronized (queue){
     
            while(queue.size() <= 0){
     
                try {
     
                	//     ,         ,wait
                    queue.wait();
                } catch (InterruptedException e) {
     
                    return null;
                }

            }
            return queue.removeFirst();
        }
    }

    public void putRequest(Requets requets){
     
        synchronized (queue){
     
            queue.addLast(requets);
            queue.notifyAll();
        }
    }
    
}
//             
public class ClientThread extends Thread{
     

    private final  RequestQueue queue;
    private final Random random;
    private final String sendValue;
    public ClientThread(RequestQueue queue , String sendValue) {
     
        this.queue = queue;
        this.sendValue = sendValue;
        random = new Random(System.currentTimeMillis());
    }

    @Override
    public void run() {
     
        for (int i = 0; i < 20 ; i++){
     
            System.out.println("Client -> request " + sendValue);
            queue.putRequest(new Requets(sendValue));
            try {
     
                Thread.sleep(1000L);
            } catch (InterruptedException e) {
     
                e.printStackTrace();
            }
        }
    }
}

서비스 측 수락

public class ServerThread extends Thread {
     

    private final RequestQueue queue;
    private final Random random;
    private volatile boolean flag = true;

    ServerThread(RequestQueue queue){
     
        this.queue = queue;
        random = new Random((System.currentTimeMillis()));
    }

    @Override
    public void run() {
     
    	//        ,        
        while (flag){
     
            Requets request = queue.getRequest();
            if(null == request){
     
                System.out.println("received the empty request");
                continue;
            }
            System.out.println("Server -> " + request.getValue());
            try {
     
                Thread.sleep(1000L);
            } catch (InterruptedException e) {
     
               return;
            }
        }
    }

	//       ,      
    public void close(){
     
        this.flag = false;
        this.interrupt();
    }

}

테스트 클래스
    public static void main(String[] args) throws InterruptedException {
     
        final RequestQueue requestQueue = new RequestQueue();
        new ClientThread(requestQueue,"ALEX").start();
        ServerThread serverThread = new ServerThread(requestQueue);
        serverThread.start();
        //             
        Thread.sleep(30000);
        serverThread.close();

    }

좋은 웹페이지 즐겨찾기