스레드(Thread)

안녕하세요 GG 임돠

이번에 쓰레드 임돠

 

package com.javac.im;
 
class ThreadEx9 {
    public static void main(String args[]) {
        ThreadEx9_1 th1 = new ThreadEx9_1();
        ThreadEx9_2 th2 = new ThreadEx9_2();
 
        th2.setPriority(7);//thread 7번 실행
 
        System.out.println("Priority of th1(-) : " + th1.getPriority() );
        System.out.println("Priority of th2(|) : " + th2.getPriority() );
        th1.start();
        th2.start();
    }
}
 
class ThreadEx9_1 extends Thread {//Thread 상속받아 사용
    public void run() {
        for(int i=0; i < 20; i++) {
            System.out.print("-");
            for(int x=0; x < 10000000; x++);//waiting 
        }
    }
}
 
class ThreadEx9_2 extends Thread {
    public void run() {
        for(int i=0; i < 20; i++) {
            System.out.print("|");
            for(int x=0; x < 10000000; x++);//waiting
        }
    }
}

 

package com.javac.im;
class ThreadEx26 {
    public static void main(String args[]) {
        MyThreadEx26 th1 = new MyThreadEx26("*");
        MyThreadEx26 th2 = new MyThreadEx26("**");
        MyThreadEx26 th3 = new MyThreadEx26("***");
        th1.start();
        th2.start();
        th3.start();
 
        try {
            Thread.sleep(2000);
            th1.suspend();
            Thread.sleep(2000);
            th2.suspend();
            Thread.sleep(3000);
            th1.resume();
            Thread.sleep(3000);
            th1.stop();
            th2.resume();
            th2.stop();
            Thread.sleep(2000);
            th3.stop();
        } catch (InterruptedException e) {}
    }
}
 
class MyThreadEx26 implements Runnable {
    static final int RUNNING = 0;
    static final int SUSPENDED = 1;
    static final int STOPPED = 2;
 
    private int state = RUNNING;
    Thread th;
 
    MyThreadEx26(String name) {
        th = new Thread(this, name); // Thread(Runnable r, String name)
    }
 
    public synchronized void setState(int state) {
        this.state = state;
 
        // state가 SUSPENDED였다가 RUNNING으로 변경되면, nofity()를 호출한다.
        if(state==RUNNING) {
            notify();
        } else {
            th.interrupt();
        }
    }
 
    public synchronized boolean checkState() {
        // state가 SUSPENDED면 wait()을 호출해서 쓰레드를 대기상태로 만들고,
        while(state==SUSPENDED) {
            try {
                wait();
            } catch(InterruptedException e) {}
        }
        // state가 STOPPED이면 true를, 그 외에는 false를 리턴한다.
        return state==STOPPED;
    }
 
    public void run() {
        String name = Thread.currentThread().getName();
 
        while(true) {
            System.out.println(name);
            try {
                Thread.sleep(1000);
            } catch(InterruptedException e) {}
 
            // state가 STOPPED이면 checkState()가 true를 반환해서 
            // while문을 벗어나게 된다.
            if(checkState()) {
                break;
            }
        } // while
        System.out.println(name + " - END");
    } // run()
 
    public void suspend() {
        setState(SUSPENDED);
    }
 
    public void resume() {
        setState(RUNNING);
    }
 
    public void stop() {
        setState(STOPPED);
    }
 
    public void start() {
        th.start();
    }
}

 

감사합니다.