C＃スレッドで保護されたメモリにアクセスしようとしたときにエラーが発生しました

Question

グローバルに宣言された2つのスレッドがあります。フォームロード時に2つのスレッドを開始します。終了ボタンをクリックします。私はパイプを作成しているwhileループと他のスレッドで接続を待っている私はバックグラウンドでDataGridを更新しています形。

私の質問が十分ではありませんが、コードが非常に大きい場合は、何が起こっているか考えてください。

おかげ

フォーム負荷のコードは

private void frmStatus_Load(object sender, EventArgs e) 
{ 
    Control.CheckForIllegalCrossThreadCalls = false; 
    RefreshStatus = new Thread(RefreshStatusForm); 
    RefreshStatus.IsBackground = true; 
    RefreshStatus.Start(); 

    th = new Thread(this.CreatePipe); 
    th.IsBackground = true; 
    th.Start(); 
} 

ボタン上にあるが

private void btnOk_Click(object sender, EventArgs e) 
{ 
    try 
    { 
     System.Object lockThis = new System.Object(); 

     lock (lockThis) 
     { 
      bCheckVal = false; 

      if (!this.bComplete) 
       stopOperation(); 

      Thread.Sleep(1000); 

      ////////These are the lines in which i get the error 
      if (!th.IsAlive) 
      { 
       th.Join(); 
      } 
      else 
      { 
       th.Abort(); 
      } 

      this.bRefresh = false; 
      Thread.Sleep(1000); 
      if (RefreshStatus.IsAlive) 
      RefreshStatus.Abort(); 
      else 
      RefreshStatus.Join(); 

      ///////////////// 
      this.bFlag = true; 
     } 

     this.Close();   
    } 
    catch (System.Exception ex) 
    { 
    } 
} 

にスレッドによって実行されるコードをクリックしてフォームを閉じるためのコードである

 public void CreatePipe() 
    { 
     try 
     { 
      PipeSecurity pipeSa = new PipeSecurity(); 
      pipeSa.SetAccessRule(new PipeAccessRule("Everyone", 
          PipeAccessRights.ReadWrite, AccessControlType.Allow)); 

      NamedPipeServerStream pipeServer = new NamedPipeServerStream(
       this.strguid,     // The unique pipe name. 
       PipeDirection.InOut,   // The pipe is bi-directional 
       NamedPipeServerStream.MaxAllowedServerInstances); 

      string strMessage = string.Empty; 
      char[] bRequest = new char[BUFFER_SIZE];// Client -> Server 
      int cbBytesRead, cbRequestBytes; 
      StreamReader sr = null; 
      byte[] bReply;       // Server -> Client 
      int cbBytesWritten, cbReplyBytes; 
      int icount = 0; 
      List<string> lsRead = new List<string>(); 
      cbBytesRead = 0; 
      CopyFileThread = new Thread(this.CopyFile); 
      CopyFileThread.IsBackground = true; 
      CopyFileThread.Start(); 
      bool bflag = false; 


      while (true) 
      { 
       this.bComplete = false; 
       bWait = true; 

       try 
       { 




        pipeServer.WaitForConnection(); 

        sr = new StreamReader(pipeServer); 

        //string message = sr.ReadToEnd(); 
        bWait = false; 
        cbRequestBytes = BUFFER_SIZE; 






        string pipeData = string.Empty; 

        pipeData = sr.Read(bRequest, 0, 255).ToString().Trim(); 
        strMessage = new string(bRequest); 




        strMessage = strMessage.Replace("\0", string.Empty); 
        if (strMessage.Contains("Aborted")) 
        { 


         if (pipeServer.IsConnected) 
         { 
          pipeServer.Flush(); 
          pipeServer.Disconnect(); 
         } 
         break; 
        } 
        else 
         if (strMessage.Contains("Completed")) 
         { 
          if (progressBar1.InvokeRequired) 
          { 
           strPercent = "100%"; 
          } 


          if (pipeServer.IsConnected) 
          { 
           pipeServer.Flush(); 
           pipeServer.Disconnect(); 
          } 
          this.bComplete = true; 
          break; 
         } 
        // 26 dec 2011 Comment code ////// 
        if (strMessage == "") 
        { 
         progressBar1.Visible = false; 
         progressBar2.Visible = true; 
        } 
        else 
        { 
         progressBar1.Visible = true; 
         progressBar2.Visible = false; 
        } 

        //// 26 dec 2011 Comment code ////// 

        string[] strStatusMessages = strMessage.Trim().Split(','); 



        // 26 dec 2011 Comment code ////// 
        pipeServer.Flush(); 

        pipeServer.Disconnect(); 



       } 
       catch (System.Exception ex) 
       { 
        //MessageBox.Show(ex.ToString()); 

       } 
      } 


      pipeServer.Close(); 


      if (CopyFileThread.IsAlive) 
       CopyFileThread.Abort(); 
      else 
       CopyFileThread.Join(); 


      MessageBox.Show("Exiting from createpipe 2 Thread :{0}", Thread.CurrentThread.ToString()); 
      return; 
     } 
     catch (Exception ex) 
     { 
      return; 
     } 
    } 

//////////////////////////////

ボイドRefreshStatusForm（）{

 while (bRefresh) 
     { 
      if (iRefresh == 1) 
      { 
       GetRefresh(); 
       iRefresh = 0; 
      } 
      else if (iRefresh == 2) 
       break; 
      Thread.Sleep(1000); 
     } 

     MessageBox.Show("Exiting from RefreshStatusForm 2 Thread :{0}", Thread.CurrentThread.ToString()); 
    } 

Answer 1

スレッドを中止または参加させる必要はありません。正常に終了させるだけの方がいいです。 "whileループで接続を待っている"あなたのスレッドでは、whileループ条件がboolとして設定され、プログラムを終了するときにboolをfalseに設定します。他のスレッドと同様の何かをします。

EDIT1 すべてのだから、最初：

while (true) 
      { 
       this.bComplete = false; 
       bWait = true; 

       try 
       { 

代わり

あなたは

私はスレッドをブロックしようとしている

pipeServer.WaitForConnection(); 

を使用

while(Running) { 

のようなものでなければなりませんそれを非同期タスクに変更する

ただし、したくない場合は、タイムアウトを頻繁に追加してください。

が続い

void btnOk_Click 

ですべてを行う必要が

Running = false; 
bRefresh = false; 

に設定され、その後のスレッドは自分自身を終了します。

EDIT2

使用して設定し、それをアップ：

AsyncCallback myCallback = new AsyncCallback(AsyncPipeCallback); 
pipeServer.BeginWaitForConnection(myCallback, null); 

このメソッド追加：接続がAsyncPipeCallbackが呼び出されたときに発生した今

private void AsyncPipeCallback(IAsyncResult Result) 
{ 
    try 
    { 
     pipeServer.EndWaitForConnection(Result); 
      sr = new StreamReader(pipeServer); 

        //string message = sr.ReadToEnd(); 
        bWait = false; 
        cbRequestBytes = BUFFER_SIZE; 






        string pipeData = string.Empty; 

        pipeData = sr.Read(bRequest, 0, 255).ToString().Trim(); 
        strMessage = new string(bRequest); 




        strMessage = strMessage.Replace("\0", string.Empty); 
        if (strMessage.Contains("Aborted")) 
        { 


         if (pipeServer.IsConnected) 
         { 
          pipeServer.Flush(); 
          pipeServer.Disconnect(); 
         } 
         break; 
        } 
        else 
         if (strMessage.Contains("Completed")) 
         { 
          if (progressBar1.InvokeRequired) 
          { 
           strPercent = "100%"; 
          } 


          if (pipeServer.IsConnected) 
          { 
           pipeServer.Flush(); 
           pipeServer.Disconnect(); 
          } 
          this.bComplete = true; 
          break; 
         } 
        // 26 dec 2011 Comment code ////// 
        if (strMessage == "") 
        { 
         progressBar1.Visible = false; 
         progressBar2.Visible = true; 
        } 
        else 
        { 
         progressBar1.Visible = true; 
         progressBar2.Visible = false; 
        } 

        //// 26 dec 2011 Comment code ////// 

        string[] strStatusMessages = strMessage.Trim().Split(','); 



        // 26 dec 2011 Comment code ////// 
        pipeServer.Flush(); 

        pipeServer.Disconnect(); 


    } 
    catch { } 
    if(Running) 
     pipeServer.BeginWaitForConnection(myCallback, null); 
} 

を。その後、それが終了すると、それがBeginWaitForConnectionであれば、まだ実行中かどうかを確認します。 btnOk_Clickで

は、このように変更します。

private void btnOk_Click(object sender, EventArgs e) 
{ 
    try 
    { 
     System.Object lockThis = new System.Object(); 

     lock (lockThis) 
     { 
      bCheckVal = false; 

      if (!this.bComplete) 
       stopOperation(); 

      Thread.Sleep(1000); 

      Running = false; 
      bRefresh = false; 

      this.bFlag = true; 
     } 

     this.Close();   
    } 
    catch (System.Exception ex) 
    { 
    } 
} 

Answer 2

「しよう保護されたメモリを読み書きする "というのは、通常、範囲外のガベージポインタまたはポインタ算術を持つことを意味します。ガベージポインターは、アプリのハングやクラッシュの原因になります。

あなたのスレッドの質問に答えるには、スレッドの代わりに.NET 4.0 Tasksを使用するのが最も簡単な方法です。タスクはキャンセルトークンを使用して構築できます。メインスレッドは、そのキャンセルトークンを使用して、店舗を閉鎖して家に帰るときのタスクスレッドを知らせることができます。