Java 개발의 멀티스레딩 구현 및 스레드 안전성

멀티 스레딩 구현 방법

● Thread 클래스를 상속하여 스레드 클래스를 만들고 run 메서드를 재정의합니다. run 메서드는 스레드가 완료해야 하는 작업을 나타냅니다. 스레드를 시작하는 개체입니다. 스레드 클래스는 이미 Thread 클래스를 상속하므로 다른 상위 클래스에서 상속할 수 없습니다.

class ThreadTest extends Thread {  

    Thread thread;  

    public ThreadTest(Thread thread) {  
      this.thread = thread;  
  }  

   @Override  
   public void run() {  
      synchronized (thread) {  
          System.out.println("getObjectLock");  
         try {  
             Thread.sleep(9000);  
       } catch (InterruptedException ex) {  
          ex.printStackTrace();  
         }  
           System.out.println("ReleaseObjectLock");  
    }  
   }  
 }

● Runnable 인터페이스를 구현하여 스레드 클래스 생성, Runnable 구현 클래스 정의, 실행 메서드 재정의

  class RunnableImpl implements Runnable {  
    
     public void run() {  
          try {  
             System.out.println("Begin sleep");  
             Thread.sleep(2000);  
             System.out.println("End sleep");  
          } catch (InterruptedException e) {  
              e.printStackTrace();  
          }  
      }  
   }

● Callable 인터페이스 구현, call() 메서드 재정의, call()이 실행 본문 역할을 함

● 스레드 풀을 사용하여 스레드 객체 java.util.concurrent.ExecutorService, java.util.concurrent.Executors;

Java는 어떻게 스레드 안전을 달성합니까? 배타적 동기화: 동기화를 위해 동기화된 키워드를 사용하는 것이 좋습니다. 동시 패키지에는 ReentrantLock 클래스가 있으며 구현 효과는 여전히 비슷합니다.

● 비차단 동기화: 완료하려면 하드웨어 지침이 필요합니다. 일반적으로 사용되는 지침은 다음과 같습니다. 테스트 및 설정 가져오기 및 증가 교환 비교 및 ​​교환(CAS) 로드 링크/저장 조건(LL/SC) 일반적인 응용 프로그램 :

의 AtomicInteger ● 동기화 솔루션 없음: 변수를 로컬 스레드에 저장하므로 여러 스레드의 동시 오류가 발생하지 않습니다. Java에서 가장 많이 사용되는 것은 ThreadLocal 클래스입니다.

Join() 메서드

thread.Join은 지정된 스레드를 현재 스레드에 추가하고 교대로 실행되는 두 스레드를 순차 실행 스레드로 병합할 수 있습니다. 예를 들어 스레드 A의 Join() 메서드가 스레드 B에서 호출되면 스레드 B는 스레드 A가 실행을 완료할 때까지 계속 실행되지 않습니다.

t.join(); //이 전에 호출 스레드가 실행을 완료하지 못하게 합니다.

t.join(1000); //t 스레드를 기다리는 중, 대기 시간은 1000밀리초이고 시간 제한은 중요하지 않습니다.

public class JoinTest implements Runnable{  

    public static int a = 0;  

    public void run() {  
        for (int k = 0; k < 5; k++) {  
            a = a + 1;  
        }  
    }  

    public static void main(String[] args) throws Exception {  
        Runnable r = new JoinTest();  
        Thread t = new Thread(r);  
        t.start();        
        t.join();//等待t线程完成后输出，可保证a=5；
        System.out.println(a);  
    }         
}

wait()

객체의 wait 메서드에는 세 가지 오버로드된 메서드가 있으며 그 중 하나는 wait( ) 다른 스레드가 현재 스레드를 깨우기 위해 inform 또는 informAll 메소드를 호출할 때까지 무기한(항상) 대기합니다. 다른 두 메소드 wait(long timeout) 및 wait(long timeout, int nanos)는 현재 스레드가 깨어나기 전에 대기하도록 허용합니다. Time, timeout은 밀리초 단위이고 nanos는 나노초 단위입니다.

notify()

notify 메서드는 대기 중인 (객체의) 스레드만 깨우고 스레드가 실행을 시작하도록 합니다. 따라서 개체를 기다리고 있는 스레드가 여러 개 있는 경우 이 방법은 스레드 중 하나만 깨우며 선택할 스레드는 운영 체제의 다중 스레드 관리 구현에 따라 달라집니다.

notifyAll()

notifyAll은 대기 중인 모든 스레드를 깨우지만 어떤 스레드가 이를 먼저 처리할지 운영 체제 구현에 따라 다릅니다.

이러한 방법은 "생산자-소비자" 문제에서 사용할 수 있습니다. 소비자는 대기열에서 개체를 기다리는 스레드이고 생산자는 대기열에서 개체를 해제하고 다른 스레드에 알리는 스레드입니다.

멀티스레딩 구현 방법

● Thread 클래스를 상속받아 스레드 클래스를 만들고, run 메서드를 재정의합니다. run 메서드는 스레드가 완료해야 하는 작업을 나타내며, 스레드 개체의 start()를 호출하여 시작합니다. 스레드, 스레드 클래스는 Thread 클래스를 상속받았으므로 다른 상위 클래스에서 상속할 수 없습니다.

class ThreadTest extends Thread {  

    Thread thread;  

    public ThreadTest(Thread thread) {  
      this.thread = thread;  
  }  

   @Override  
   public void run() {  
      synchronized (thread) {  
          System.out.println("getObjectLock");  
         try {  
             Thread.sleep(9000);  
       } catch (InterruptedException ex) {  
          ex.printStackTrace();  
         }  
           System.out.println("ReleaseObjectLock");  
    }  
   }  
 }

● Runnable 인터페이스를 구현하여 스레드 클래스 생성, Runnable 구현 클래스 정의, 실행 메서드 재정의

  class RunnableImpl implements Runnable {  
    
      public void run() {  
          try {  
              System.out.println("Begin sleep");  
              Thread.sleep(2000);  
              System.out.println("End sleep");  
          } catch (InterruptedException e) {  
              e.printStackTrace();  
           }  
       }  
   }

● Callable 인터페이스 구현, call() 메서드 재정의, call()이 실행 본문 역할을 함

● 스레드 풀을 사용하여 스레드 객체 java.util.concurrent.ExecutorService, java.util.concurrent.Executors;

Java는 어떻게 스레드 안전을 달성합니까? 배타적 동기화: 동기화를 위해 동기화된 키워드를 사용하는 것이 좋습니다. 동시 패키지에는 ReentrantLock 클래스가 있으며 구현 효과는 여전히 비슷합니다.

● 비차단 동기화: 완료하려면 하드웨어 지침이 필요합니다. 일반적으로 사용되는 지침은 다음과 같습니다. 테스트 및 설정 가져오기 및 증가 교환 비교 및 ​​교환(CAS) 로드 링크/저장 조건(LL/SC) 일반적인 응용 프로그램 :

의 AtomicInteger ● 동기화 솔루션 없음: 로컬 스레드에 변수를 저장하면 다중 스레드 동시성에서 오류가 발생하지 않습니다. Java에서 가장 많이 사용되는 것은 ThreadLocal 클래스입니다.

Join() 메서드

thread.Join은 지정된 스레드를 현재 스레드에 추가하고 교대로 실행되는 두 스레드를 순차 실행 스레드로 병합할 수 있습니다. 예를 들어 스레드 A의 Join() 메서드가 스레드 B에서 호출되면 스레드 B는 스레드 A가 실행을 완료할 때까지 계속 실행되지 않습니다.

t.join(); //이 전에 호출 스레드가 실행을 완료하지 못하게 합니다.

t.join(1000); //t 스레드를 기다리는 중, 대기 시간은 1000밀리초이고 시간 제한은 중요하지 않습니다.

public class JoinTest implements Runnable{  

    public static int a = 0;  

    public void run() {  
        for (int k = 0; k < 5; k++) {  
            a = a + 1;  
        }  
    }  

    public static void main(String[] args) throws Exception {  
        Runnable r = new JoinTest();  
        Thread t = new Thread(r);  
        t.start();        
        t.join();//等待t线程完成后输出，可保证a=5；
        System.out.println(a);  
    }         
}

wait()

객체의 wait 메서드에는 세 가지 오버로드된 메서드가 있으며 그 중 하나는 wait( ) 다른 스레드가 현재 스레드를 깨우기 위해 inform 또는 informAll 메소드를 호출할 때까지 무기한(항상) 대기합니다. 다른 두 메소드 wait(long timeout) 및 wait(long timeout, int nanos)는 현재 스레드가 깨어나기 전에 대기하도록 허용합니다. Time, timeout은 밀리초 단위이고 nanos는 나노초 단위입니다.

notify()

notify 메서드는 대기 중인 (객체) 스레드만 깨우고 스레드가 실행을 시작하도록 합니다. 따라서 개체를 기다리고 있는 스레드가 여러 개 있는 경우 이 방법은 스레드 중 하나만 깨우며 선택할 스레드는 운영 체제의 다중 스레드 관리 구현에 따라 달라집니다.

notifyAll()

notifyAll은 대기 중인 모든 스레드를 깨우지만 어떤 스레드가 이를 먼저 처리할지 운영 체제 구현에 따라 다릅니다.
이러한 방법은 "생산자-소비자" 문제에서 사용할 수 있습니다. 소비자는 대기열에서 개체를 기다리는 스레드이고 생산자는 대기열에서 개체를 해제하고 다른 스레드에 알리는 스레드입니다.

위 내용은 Java 개발의 멀티스레딩 구현 및 스레드 안전성의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!