스레드를 사용하여 클래스를 올바르게 처리 함

Question

상당히 복잡한 멀티 스레드 Windows 서비스가 작동하지만 올바르게 정리하는 방법을 알 수 없습니다. 아래는 내가 가지고있는 것을 보여주는 몇 가지 [의사] 코드입니다. 실제 코드는 훨씬 복잡하고 복사/붙여 넣기에는 너무 많습니다.

기본적으로 작업을 수행 할 스레드를 만드는 클래스 요청이 있습니다. 리스너에 새 요청이 들어 오면 프로세서로 보내어 새 요청을 만들고 요청 목록을 유지 관리합니다. 서비스가 중지되면 목록의 모든 요청을 정리합니다. 그러나 요청 작업이 완료되면 클래스의 한 인스턴스를 정리하는 방법은 무엇입니까?

도움 주셔서 감사합니다.

넬슨

class Service 
{ 
    Listener listener; 
    Processor processor; 

    OnStart() 
    { 
    processor = new Processor(); 
    listener = new Listener(processor); 
    } 

    OnStop() 
    { 
    listener.Dispose(); 
    processor.Dispose(); 
    } 
} 

class Listener 
{ 
    Thread thread; 
    bool terminate = false; 

    Listener(Processor processor) 
    { 
    thread = new Thread(DoWork); 
    thread.Start(processor); 
    } 

    DoWork(Processor processor) 
    { 
    WaitForConnection(NewConnection); 
    } 

NewConnection(String data) 
{ 
    processor.NewRequest(data); 

    if (terminate) 
     return; 

    WaitForConnection(NewConnection); 
} 

    Dispose() 
    { 
    terminate = true; 
    thread.Join(); 
    } 
} 

class Processor 
{ 
    //I need to maintain this list so that when the service stops I can cleanly close down 
    List<Request> requests = new List<Request>(); 

    NewRequest(string data) 
    { 
    request.Add(new Request(data)); 
    } 

    Dispose() 
    { 
    //Cleanup each request 
    foreach (Request request in requests) 
    { 
     request.Dispose(); 
    } 
    } 
} 

class Request 
{ 
    Thread thread; 
    bool terminate; 

    Request(string data) 
    { 
    while (true) 
    { 
     //Do some work 
     Thread.Sleep(1000); 

     if (doneWorking) 
     break; 

     if (terminate) 
     return; 
    } 

    //We're done. If I return this thread stops. But how do I properly remove this Request instance from the Processor.requests list? 
    } 

    Dispose() 
    { 
    terminate = true; 
    thread.Join(); 
    } 
} 

Answer 1

이 거친 스케치입니다 :

delegate void CompletedRequest(Request req); 

class Processor : ITrackCompletion 
{ 
    //I need to maintain this list so that when the service stops I can cleanly close down 
    List<Request> requests = new List<Request>(); 

    public void NewRequest(string data) 
    { 
     lock(requests) 
      request.Add(new Request(data), Complete); 
    } 

    public void Complete(Request req) 
    { 
     lock (requests) 
      requests.Remove(req); 
    } 

    public void Dispose() 
    { 
     //Cleanup each request 
     foreach (Request request in requests.ToArray()) 
     { 
      request.Dispose(); 
     } 
    } 
} 

class Request 
{ 
    Thread thread; 
    bool terminate; 

    public Request(string data, CompletedRequest complete) 
    { 
     try 
     { 
      while (true) 
      { 
       //Do some work 
       Thread.Sleep(1000); 

       if (doneWorking) 
        break; 

       if (terminate) 
        return; 
      } 
     } 
     finally 
     { 
      //We're done. If I return this thread stops. But how do I properly remove this Request instance from the Processor.requests list? 
      complete(this); 
     } 
    } 

    void Dispose() 
    { 
     terminate = true; 
     thread.Join(); 
    } 
} 

Answer 2

하나의 가능성은 대리인의 형태로 요청에 콜백을 전달하는 것입니다 : "당신이 처리를 완료 한 때, 나에게 다시 전화 해". 그런 다음 요청 처리가 끝나면 콜백을 실행하고 정리를 처리하게하십시오.

한 가지주의해야 할 사항 : 목록을 처리하려고 시도한 다음 다른 스레드의 목록에서 항목을 제거하려고하면 문제가 발생합니다. 아마 thread-safe 한 방법으로 액세스되는 플래그를 유지해야하고 목록의 모든 것을 처리하기 시작하면 얻은 콜백을 무시하십시오.