13.1 프로세스와 쓰레드 (process & thread)

• 프로세스 : 실행 중인 프로그램 , 자원 (resource) 과 쓰레드로 구성

• 쓰레드

  • 프로세스 내에서 실제 작업을 수행
  • 모든 프로세스는 최소한 하나의 쓰레드를 가진다

• 프로세스 : 쓰레드

  • 공장 : 일꾼

  

하나의 새로운 프로세스를 생성하는 것보다 하나의 새로운 쓰레드를 생성하는 것이 더 적은 비용이 든다

• 2프로세스 (공장 2개) 1쓰레드 vs 1프로세스 2쓰레드 (1공장 2일꾼 적은 비용)

• Java Servlet
  • 멀티스레드 지원해서 인기!

대부분의 프로그램이 멀티 쓰레드로 작성! 항상 장점이 있는 것은 아닙니다

• 장점
  • 시스템 자원을 보다 효율적으로 사용
  • 사용자에 대한 응답성 향상
  • 작업이 분리되어 코드 간결화
• 단점
  • 동기화에 주의
  • 교착상태가 발생하지 않도록 주의 ( 각 스레드가 자원을 들고 다른 스레드에 반환해 주지 않는 것)
  • 각 스레드가 효율적으로 고르게 실행될 수 있어야함
    • 특정 스레드가 작업을 못할 수 있음 (기아)

13-3 스레드의 구현과 실행

1. Thread클래스를 상속

   class MyThread extends Thread{
   
   		public void run()
   
   }
   

2. Runnable 인터페이스를 구현

   class MyThread2 extends Runnable{
   
   		public void run() //Runnable 인터페이스의 추사메서드 run() 을 구현
   
   }
   

package kr.or.test.thread;

/*

 */
public class Ex13_1 {
      public static void main(String[] args) {
            ThreadEx1_1 t1 = new ThreadEx1_1();

            Runnable r = new ThreadEx1_2();
            Thread t2 = new Thread(r);

            t1.start();
            t2.start();

      }

}

class ThreadEx1_1 extends Thread { // Thread 클래스를 상속해서 스레드 구현
      @Override
      public void run() {
            for (int i = 0; i < 200; i++) {
                  System.out.println(getName());
            } //조상인 Thread의 getName() 을 호출
      }
}
class ThreadEx1_2 implements Runnable { //Runnable 인터페이스를 구현해서 스레드 생성
      @Override
      public void run() {
            for (int i = 0; i < 200; i++) {
                  //Thread.currentThread() - 현재 실행중인 Thread를 반환합니다
                  System.out.println(Thread.currentThread().getName());
            }

      }
}

13-5 스레드의 실행 - start()

• 스레드를 생성한 후 start() 를 호출해야 스레드가 작업을 시작합니다
• OS 의 스케쥴러가 스레드를 실행순서를 결정합니다

13-6 start() 와 run()

• start 의 경우
  • 별도 호출스택을 생성하고 스레드 독립적으로 작업을 수행하게 됩니다
• run() 의 경우 콜스택에 별도의 run() 이 스택이 쌓여서 수행!
  • 이 경우 멀티 스레드 작업 수행이 아닙니다

13-7 main 쓰레드

• main 메서드의 코드를 구행하는 쓰레드

• 스레드는 사용자 스레드 와 데몬 스레드 두 종류가 존재

  • 실행 중인 사용자 스레드가 하나도 없을 때 프로그램은 종료된다.

  package kr.or.test.thread;
  
  /*
  
   */
  public class Ex13_11 {
        static long startTime = 0;
  
        public static void main(String[] args) {
              ThreadEx11_1 th1 = new ThreadEx11_1();
              ThreadEx11_2 th2 = new ThreadEx11_2();
  
              th1.start();
              th2.start();
  
              startTime = System.currentTimeMillis();
              try {
                    th1.join(); //main 스레드가 th1의 작업이 끝날 때까지 기다린다.
                    th2.join(); // main 스레드가  th2 의 작업이 끝날 떄까지 기다립니다
  
              } catch (InterruptedException e) {
                    System.out.println(e.getMessage());
  
              }
              System.out.print("소요시간 : " + (System.currentTimeMillis() - startTime));
        }
  
  }
  
  class ThreadEx11_1 extends Thread {
        @Override
        public void run() {
              for (int i = 0; i < 300; i++) {
                    System.out.print(new String("-"));
  
              }
        }
  }
  
  class ThreadEx11_2 extends Thread {
        @Override
        public void run() {
              for (int i = 0; i < 300; i++) {
                    System.out.print(new String("|"));
  
              }
        }
  }
  

13-11 스레드의 I/O 블락킹 (blocking)

• I/O
  • input/output
  • 입력/ 출력 = 입출력
• I/O 블락킹
  • 입출력시 작업 중단되는 것

package kr.or.test.thread;

import javax.swing.*;

/*

 */
public class ThreadEx6 {
      public static void main(String[] args) {
            ThreadEx7_1 th1 = new ThreadEx7_1();
            th1.start();

            String input = JOptionPane.showInputDialog("아무 값이나 입력하세요.");
            System.out.println("입력하신 값은 " + input + " 입니다");

      }

}

class ThreadEx7_1 extends Thread {
      @Override
      public void run() {
            for (int i = 10; i > 0; i--) {
                  System.out.println("i = " + i);
                  try {
                        Thread.sleep(1000);
                  } catch (Exception e) {
                        System.out.println(e.getMessage());
                  }
            }
      }
}

13-14 쓰레드의 우선순위 (priority of thread)

• 작업의 중요도에 따라 스레드의 우선순위를 다르게 하여 특정 스레드가 더 많은 작업시간을 갖음

  package kr.or.test.thread;
  
  /*
  
   */
  public class Ex13_6 {
        public static void main(String[] args) {
              ThreadEx6_1 th1 = new ThreadEx6_1();
              ThreadEx6_2 th2 = new ThreadEx6_2();
  
              th2.setPriority(7);
  
              System.out.println("th1 = " + th1.getPriority());
              System.out.println("th2= " + th2.getPriority());
  
              th1.start();
              th2.start();
        }
  
  }
  
  class ThreadEx6_1 extends Thread {
        @Override
        public void run() {
              for (int i = 0; i < 300; i++) {
                    System.out.print("-");
                    for(int x= 0 ;x<1000000;x++);
              }
        }
  }
  
  class ThreadEx6_2 extends Thread {
        @Override
        public void run() {
              for (int i = 0; i < 300; i++) {
                    System.out.print("|");
                    for(int x= 0 ;x<1000000;x++);
  
              }
  
        }
  }
  

13-16 스레드 그룹

• 서로 관련된 스레드를 그룹으로 묶어서 다루기 위한 것
• 모든 스레드는 반드시 하나의 스레드 그룹에 포함되어 있어야 한다
• 스레드 그룹을 지정하지 않고 생성한 스레드는 main 스레드 그룹 에 속한다
• 자신을 생성한 스레드(부모 스레드)의 그룹과 우선순위를 상속받는다

13-18 데몬 스레드 (daemon thread)

• 일반 스레드의 작업을 돕는 보조적인 역할을 수행합니다
• 일반 스레드가 모두 종료되면 자동적으로 종료된다
• 가비지 컬렉터 , 자동저장, 화면 자동 갱신 등에 사용된다
• 무한 루프와 조건문을 이용해서 실행 후 대기하다가 특정 조건이 만족되면 작업을 수행하고 다시 대기하도록 작성
• serDaemon(boolean on)은 반드시 start()를 호출하기 전에 실행되어야 한다. 그렇지 않으면 illegalThreadException이 발생한다.

13-20 스레드의 상태

• 그네와 벤치! 일시정지 : 벤츠에서 쉬는 것 / 스레드 작업 : 그네타기

13-21 스레드의 실행제어

• 스레드의 실행을 제어할 수 있는 메서드가 제공된다

  

  • join
    • 다른 스레드가 작업하는 것을 기다립니다
  • interrupt
    • join , sleep 상태를 종료
  • static void sleep , static void yield
    • 이 두 메서의 경우 자기 자신에게만 호출할 수 있다

13-22 sleep()

• 현재 스레드를 지정된 시간동안 멈추게 한다
• 스레드 자기 자신에 대해서 동작합니다! staic이기에!