교착상태 (Deadlock)

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71

import threading
import time

class Resource:
    def __init__(self, name):
        self.name = name
        self.lock = threading.Lock()
    
    def acquire(self, process_name):
        print(f"{process_name}가 {self.name} 획득 시도")
        self.lock.acquire()
        print(f"{process_name}가 {self.name} 획득 성공")
    
    def release(self, process_name):
        print(f"{process_name}가 {self.name} 반환")
        self.lock.release()

def process_task(process_name, first_resource, second_resource):
    """
    교착상태를 발생시키는 프로세스 작업을 시뮬레이션합니다.
    각 프로세스는 두 개의 자원을 순차적으로 획득하려 시도합니다.
    """
    try:
        # 첫 번째 자원 획득
        first_resource.acquire(process_name)
        print(f"{process_name}가 작업 중…")
        time.sleep(1)  # 다른 프로세스가 두 번째 자원을 획득할 시간을 줌
        
        # 두 번째 자원 획득 시도
        second_resource.acquire(process_name)
        print(f"{process_name}가 모든 자원 획득 성공")
        
        # 작업 수행
        time.sleep(1)
        
        # 자원 반환
        second_resource.release(process_name)
        first_resource.release(process_name)
        
    except Exception as e:
        print(f"{process_name} 오류 발생: {e}")

def main():
    # 두 개의 자원 생성
    resource_A = Resource("Resource A")
    resource_B = Resource("Resource B")
    
    # 두 개의 프로세스 생성
    # Process 1은 A -> B 순서로 자원 획득 시도
    # Process 2는 B -> A 순서로 자원 획득 시도
    process1 = threading.Thread(
        target=process_task,
        args=("Process 1", resource_A, resource_B)
    )
    process2 = threading.Thread(
        target=process_task,
        args=("Process 2", resource_B, resource_A)
    )
    
    # 프로세스 시작
    process1.start()
    process2.start()
    
    # 프로세스 종료 대기
    process1.join()
    process2.join()

if __name__ == "__main__":
    print("교착상태 시뮬레이션 시작")
    main()
    print("시뮬레이션 종료")