AsyncCallback 함수 외부에서 비동기 스트림 중지

Question

Stream 객체가 있고 BeginRead를 사용하여 버퍼로 읽기 시작합니다. 읽기가 완료되면 AsyncCallback 함수가 호출됩니다. 이 함수 내에서 사용자가 다음 '블록'을 가져오고 BeginRead 프로세스를 다시 시작할지 확인할 수 있습니다.

내가 가진 문제는 스트림이 여전히 읽히는 동안 (AsyncCallback 함수가 호출되기 전에) 사용자가 스트림 읽기를 취소 할 수 있도록 취소 할 수 있다는 것입니다.

이 문제를 자세히 설명하기 위해 Streams Read 메서드 나 비동기 BeginRead 메서드로 BackgroundWorker를 사용하면 같은 결과를 얻은 것으로 보입니다. Read/BeginRead 메소드가 완료 될 때까지 기다리는 시간을 기다려야 만 스트림이 읽기를 중지해야하는지 확인할 수 있습니다.

편집 :이 코드는 아래의 작업을해야한다, 나는 백만 마일 떨어진 나는 그것이 완벽 의심으로이 솔루션을 보여 주는하지만 그것이 아니라, 버그 몇 가지를 가질 수 있도록 C#으로 괜찮은 아무것도되지 해요 .

요약하면 CWorkManager는 특정 수의 스레드 (CWorkerDetail 클래스에 보유 됨)를 관리합니다. 각 CWorkerDetail은 작업자가 시작될 수 있음을 나타내는 EWaiting, 작업자가 소스에서 읽는 것을 의미하는 EReading, 작업자를 즉시 ​​중지 할 수있는 상태, 읽을 수있는 데이터를 디스크에 저장하는 EWriting, 이 즉시 stoppp 수 없으며이 프로세스는 스레드가 중지되기 전에 완료해야합니다. 마지막으로 작업자가 가능한 빨리 중단되어야한다면 관리자가 설정하는 EAborting이 있습니다. 지금 이것은 작업자가 중단 될 수없는 (디스크에 쓰는 것과 같은) 작업의 중간에있는 경우에만 설정됩니다.

바로 지금은 주 솔루션 (기본적으로 StopWorker 함수가 CWorker의 플래그를 확인하여 즉시 중단 할 수 있는지 확인하는 것)이 복잡해 지므로 실제로는 읽기 또는 쓰기가 수행되지 않습니다. 우리는 단순히 스레드를 잠자기 상태로 만듭니다.

GUI 사이드는 목록 상자 (각 작업자의 상태를 보여주는)와 중지 및 시작 버튼만으로 매우 간단합니다.

---

using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Threading; 


namespace ThreadApplication { 


    //A worker that spawns a number of threads (managed internally) that does nothing useful at all. 
    public class CWorkManager { 


     //The status of the worker. 
     public enum EWorkerStatus { 
      EWaiting, 
      EReading, 
      EWriting, 
      EAborting, 
     } 


     //Holds all data relevant to the worker. 
     private class CWorkerDetails { 

      //Simple variables. 
      private readonly Object _Lock=new Object(); 
      private Thread gThread; 
      private EWorkerStatus gStatus; 
      private CWorkManager gParentInstance; 
      private int gIndex; 

      //Simple constructor. 
      public CWorkerDetails(int aIndex, CWorkManager aParentInstance, Thread aThread, EWorkerStatus aStatus) { 
       gIndex=aIndex; 
       gParentInstance=aParentInstance; 
       gThread=aThread; 
       gStatus=aStatus; 
      } 

      //Simple get set methods. 
      public Thread GetThread() { lock(_Lock) { return gThread; } } 
      public EWorkerStatus GetStatus() { lock(_Lock) { return gStatus; } } 

      //Sets the status and automatically updates the GUI. 
      public void SetStatus(EWorkerStatus aStatus) { 
       lock(_Lock) { 
        gStatus=aStatus; 
        Form1.gInstance.Invoke(new UpdateGUIDelegate(gParentInstance.UpdateGUI), new object[] { gIndex, GetStatus() }); 
       } 
      } 

     } 


     //Worker variable. 
     private List<CWorkerDetails> gWorkers; 


     //Simple constructor. 
     public CWorkManager(int aWorkerCount){ 
      gWorkers=new List<CWorkerDetails>(); 
      for(int tIndex=0; tIndex<aWorkerCount; tIndex++) 
       gWorkers.Add(null); 
     } 


     //Creates and starts the worker. 
     public void StartWorker(int aWorkerIndex) { 

      //Create a new worker if there is none or if it is waiting to start. 
      if(gWorkers.ElementAt(aWorkerIndex)==null||gWorkers.ElementAt(aWorkerIndex).GetStatus()==EWorkerStatus.EWaiting) 
       gWorkers[aWorkerIndex]=new CWorkerDetails(aWorkerIndex, this, new Thread(new ParameterizedThreadStart(WorkerMethod)), EWorkerStatus.EWaiting); 

      //If the worker is waiting to start, then start. 
      if(gWorkers.ElementAt(aWorkerIndex).GetStatus()==EWorkerStatus.EWaiting) 
       gWorkers.ElementAt(aWorkerIndex).GetThread().Start(gWorkers.ElementAt(aWorkerIndex)); 
     } 


     //Stops the worker. 
     public void StopWorker(int aWorkerIndex) { 

      //Do nothing if the worker is null. 
      if(gWorkers.ElementAt(aWorkerIndex)==null) 
       return; 

      //Do nothing if the worker is waiting. 
      if(gWorkers.ElementAt(aWorkerIndex).GetStatus()==EWorkerStatus.EWaiting) 
       return; 

      //If the worker is reading we can abort instantly. 
      if(gWorkers[aWorkerIndex].GetStatus()==EWorkerStatus.EReading) { 
       gWorkers[aWorkerIndex].GetThread().Abort(); 
       gWorkers[aWorkerIndex].SetStatus(EWorkerStatus.EWaiting); 
       return; 
      } 

      //Since the worker is not reading or waiting, we have to request the 
      //worker to abort by itself. 
      gWorkers[aWorkerIndex].SetStatus(EWorkerStatus.EAborting); 

     } 


     //Updates the GUI. 
     private delegate void UpdateGUIDelegate(int aIndex, EWorkerStatus aStatus); 
     private void UpdateGUI(int aIndex, EWorkerStatus aStatus) { 
      Form1.gInstance.SetThreadStatus(aIndex, aStatus); 
     } 


     //This method is where all the real work happens. 
     private void WorkerMethod(Object aWorker) { 

      //Fetch worker. 
      CWorkerDetails mWorker=(CWorkerDetails)aWorker; 

      //Loop forever, the thread will exit itself when required. 
      while(true) { 

       //Is the worker status aborting - if so we stop here. 
       if(mWorker.GetStatus()==EWorkerStatus.EAborting) { 
        mWorker.SetStatus(EWorkerStatus.EWaiting); 
        return; 
       } 

       //This would normally be reading from a stream which would cause the thread 
       //to block, simulate this by just sleeping the thread. 
       mWorker.SetStatus(EWorkerStatus.EReading); 
       Thread.Sleep(3000); 

       //Is the worker status aborting - if so we stop here. 
       if(mWorker.GetStatus()==EWorkerStatus.EAborting) { 
        mWorker.SetStatus(EWorkerStatus.EWaiting); 
        return; 
       } 

       //All data has been read, set status to writing and again simulate by 
       //sleeping the thread. 
       mWorker.SetStatus(EWorkerStatus.EWriting); 
       Thread.Sleep(3000); 

      } 

     } 

    } 


} 

: 모든 코드는 ...

CWorkManager.cs, 다음과 같습니다이 사람을 도움이되지만 내가 말한대로 내가 너무 버그 등을 조심하시기 바랍니다 C#을 화려한 아니에요 희망

---

Form1.CS :

---

은 포함 :

• 목록 상자 (ListBox_WorkerStatus)
• A 버튼 (Button_Start)
• A 버튼 (Button_Stop)

---

using System; 
using System.Collections.Generic; 
using System.ComponentModel; 
using System.Data; 
using System.Drawing; 
using System.Linq; 
using System.Text; 
using System.Windows.Forms; 


namespace ThreadApplication { 


    public partial class Form1:Form { 


     public static Form1 gInstance; 
     private CWorkManager gManager; 


     public Form1() { 
      InitializeComponent(); 
      Button_Start.Click+=new EventHandler(Button_Start_Click); 
      Button_Stop.Click+=new EventHandler(Button_Stop_Click); 
      gInstance=this; 
      for(int tIndex=0; tIndex<5; tIndex++) 
       ListBox_WorkerStatus.Items.Add("Created"); 
      gManager=new CWorkManager(ListBox_WorkerStatus.Items.Count); 
     } 


     public void SetThreadStatus(int aIndex, CWorkManager.EWorkerStatus aStatus) { 
      ListBox_WorkerStatus.Items[aIndex]=aStatus.ToString(); 
     } 


     private void Button_Start_Click(object sender, EventArgs e) { 
      if(ListBox_WorkerStatus.SelectedIndex>=0) { 
       gManager.StartWorker(ListBox_WorkerStatus.SelectedIndex); 
      } 
     } 


     private void Button_Stop_Click(object sender, EventArgs e) { 
      if(ListBox_WorkerStatus.SelectedIndex>=0) { 
       gManager.StopWorker(ListBox_WorkerStatus.SelectedIndex); 
      } 
     } 

     private void Form1_FormClosed(object sender, FormClosedEventArgs e) { 
      for(int tIndex=0; tIndex<ListBox_WorkerStatus.Items.Count; tIndex++) { 
       gManager.StopWorker(tIndex); 
      } 
     } 


    } 


} 

---

Answer 1

사용 BackgroundWorker에

BackgroundWorker backgroundWorker1= new backgroundWorker() 

private void InitializeBackgroundWorker() 
{ 
     backgroundWorker1.DoWork += 
      new DoWorkEventHandler(backgroundWorker1_DoWork); 

     backgroundWorker1.WorkerSupportsCancellation = true; 
} 



private void backgroundWorker1_DoWork(object sender, 
     DoWorkEventArgs e) 
{ 
     BackgroundWorker worker = sender as BackgroundWorker; 

     e.Result = YourWorkToDo(); 
} 

public void Start() 
{ 
    backgroundWorker1.RunWorkerAsync() 
} 

public voic Cancel() 
{ 
    backgroundWorker1.CancelAsync(); 
{ 

당신이 원하는 경우 더 많은 도움이 휴가 코멘트

Answer 2

Cancel BeginRead 살펴 보시기 바랍니다이

내가 확실히 이해하지 못하는 그런는 죄송합니다 도움이 될거야 방법