자바 쓰레드 질문 (join, synchronized)

Question

안녕하세요 자바 공부 중에 join, synchronized 순서 제어하는 연습했는데synchronized만 사용했을때 결과는 맞지만 순서 출력이 안 맞게 나왔습니다.join 찾아보고 사용 시 각 쓰레드의 종료를 기다린다고 나오더군요그럼 join만 써도 쓰레드 종료를 기다리기에th1 다음 th2로 순서에 맞게 실행되는게 맞지 않나요?결론이 join + synchronized 해야 결과도 맞고 출력 순서도 맞는데 책에도 설명이 잘 없어서요... 혹시 아시는분 계실까요??아래 코드 및 사진도 올렸습니다..package 쓰레드테스트2; // 계좌정보 public class _06_Account { // 멤버변수 private String accountNo; // 계좌번호 010-1111-2222 010-8888-9999 private String ownerName; // 예금주명 김태희 비 private int balance; // 잔액 2000000 1000000 // 디폴트 생성자 public _06_Account() {} // 매개변수 생성자 public _06_Account(String accountNo, String ownerName, int balance) { this.accountNo = accountNo; this.ownerName = ownerName; this.balance = balance; } // 멤버메서드(Getter, Setter) public String getAccountNo() { return accountNo; } public void setAccountNo(String accountNo) { this.accountNo = accountNo; } public String getOwnerName() { return ownerName; } public void setOwnerName(String ownerName) { this.ownerName = ownerName; } public int getBalance() { return balance; } public void setBalance(int balance) { this.balance = balance; } // 입금하다 public void deposit(int amount) { balance += amount; } // 출금하다 public int withdraw(int amount) { if(balance < amount) return 0; balance -= amount; return balance; } }package 쓰레드테스트2; public class _06_SharedArea { // 멤버변수 _06_Account account1; _06_Account account2; public _06_SharedArea(_06_Account account1, _06_Account account2) { this.account1 = account1; this.account2 = account2; } // 계좌이체를 하다 => _06_TransferThread에서 5번 호출 synchronized void transfer(int money) { // void transfer(int money) { account1.withdraw(money); System.out.print(account1.getOwnerName()+" 출금합니다."); System.out.println(" - 잔액 : " +account1.getBalance()); account2.deposit(money); System.out.print(account2.getOwnerName()+" 입금되었습니다. "); System.out.println(" - 잔액 : " +account2.getBalance()); } // 잔액합계를 구한다. => _06_TotalBalanceThread에서 3번 호출 synchronized int getBalanceTotal() { // int getBalanceTotal() { return account1.getBalance() + account2.getBalance(); } } package 쓰레드테스트2; public class _06_TotalBlanceThread extends Thread { //멤버변수 private _06_SharedArea sa; public _06_TotalBlanceThread(_06_SharedArea sa) { this.sa = sa; } @Override public void run() { String ownerName = sa.account1.getOwnerName(); int totalCount = 0; if (ownerName == "김태희") { for(int i=0; i<3; i++) { System.err.println("계좌 잔액 합계 : (" +sa.account1.getOwnerName()+" + "+sa.account2.getOwnerName()+") = "+ sa.getBalanceTotal()); System.out.println(); try { Thread.sleep(2000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } else { for(int i=0; i<2; i++) { System.err.println("계좌 잔액 합계 : (" +sa.account1.getOwnerName()+" + "+sa.account2.getOwnerName()+") = "+ sa.getBalanceTotal()); System.out.println(); try { Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } } } } //run } package 쓰레드테스트2; public class _06_TransferThread extends Thread { // 멤버변수 private _06_SharedArea sa; public _06_TransferThread(_06_SharedArea sa) { this.sa = sa; } @Override public void run() { String ownerName = sa.account1.getOwnerName(); if (ownerName == "김태희") { for(int i=0; i<3; i++) { sa.transfer(1000); } } else { for(int i=0; i<2; i++) { sa.transfer(2000); } } }// run } package 쓰레드테스트2; import java.util.HashMap; import java.util.Iterator; import java.util.Map; public class _06_Main { public static void main(String[] args) { Map transferList = new HashMap<>(); _06_Account kim = new _06_Account("010-1111-1111","김태희",10000); _06_Account rain = new _06_Account("010-2222-2222","비",10000); _06_Account iu = new _06_Account("010-3333-3333","아이유",20000); _06_Account sook = new _06_Account("010-4444-4444","김숙",20000); transferList.put("김태희", kim); transferList.put("아이유", iu); Iterator it = transferList.keySet().iterator(); _06_SharedArea sa = null; while(it.hasNext()) { String key = it.next(); if (key == "김태희") { sa = new _06_SharedArea(kim,rain); } else { sa = new _06_SharedArea(iu,sook); } _06_TransferThread th1 = new _06_TransferThread(sa); _06_TotalBlanceThread th2 = new _06_TotalBlanceThread(sa); th1.start(); th2.start(); try { th1.join(); th2.join(); } catch (InterruptedException e) { e.printStackTrace(); } } } } join + synchronized 사용시 synchronized 만 사용시

mirheeoj · Answer

th1.start(); th2.start(); try { th1.join(); th2.join(); } catch (InterruptedException e) { e.printStackTrace(); }이 코드만 보면 th1의 실행이 끝나고 나서 th2가 실행된다는 보장이 없습니다. 위 코드로 확신할 수 있는 건 예외 발생 없이 코드 블럭이 끝났을 때 th1과 th2가 모두 종료되었다는 것 정도겠네요.th1이 종료되고 나서 th2가 시작하게 하려면 코딩도 그렇게 하시면 됩니다. th1.start - th1.join - th2.start - th2.join 순으로 호출하면 되는거죠. 이럴거면 그냥 스레드를 안 쓰면 되지만, 일단 넘어갑니다. 호출순서가 조금이라도 달라지면 th1, th2내부에서 자체적으로 서로 동기화를 하지 않는 이상에는 실행 순서 보장을 할 수 없습니다.synchronize는 동시 실행을 못하게 하는 것이므로 순서가 보장되지 않는게 맞고요.

장독깨기 · Answer

A 와 B 태스크를 동시에 실행시키기 위해서는 스레드를 생성해서 실행 시켜야 합니다.그니까, 스레드는 실행 순서가 없습니다. 동시에 실행 시키려는 목적이니까요.근데, 간혹 또는 굳이 순서에 맞게 실행하고 싶다면,가령, 이체를 하고 잔액을 조회하고,... 이걸 반복하고 싶다면,스레드간에 신호를 보낼 수 있고 신호를 받을때까지 대기를 할 수 있습니다.이 부분은 wait, notify 를 한 번 알아보세요.

자바 쓰레드 질문 (join, synchronized)

2개의 답변

기술 목록