1

「ストリームを読み取れませんでした。」というエラーが出るのですが、
原因を特定することが出来ないので質問させていただきました。

現在クラス変数で宣言している1つのストリーム変数に対して、
二つのマルチスレッドで、交互にストリームを生成・上書きを1秒おきに繰り返しています。
そして、そのストリームを別スレッドで定期的にBinaryReaderで読み込んでいます。

マルチスレッドによって、常にストリーム変数にストリームが格納されている状態なので、今回のようなエラーは起こりえないと考えていますが、ランダムなタイミングで今回のエラーが発生する状況です。
このエラーの解決方法や原因が分かる方がいましたら、ご教授をお願いします。

~大まかですがソースを載せます

// ストリーム
private Stream stream;

public void reader()
{
 // ストリーム生成処理呼び出し
 Thread thread_A = new Thread(new ThreadStart(A));
 thread_A.Start();

 while (true)
 {
   try
   {
     using (BinaryReader reader = new BinaryReader(this.stream))
     {
       読み取り処理
     }
     reader.Close();
     Thread.Sleep(1000);
   }
   catch{
   ストリームが読み取れませんでした。
   }
 }

private void A()
{
    while (true)
    {
       // ストリーム生成処理
      thread thread_A = new Thread(new ThreadStart(B));
      thread_A.Start();
      Thread.Sleep(1000);

      // ストリーム生成処理
      Thread thread_B = new Thread(new ThreadStart(C));
      thread_B.Start();
      Thread.Sleep(1000);
    }
 }

private void B()
{ 
   this.stream = File.Open(path, FileMode.Open, FileAccess.Read,     FileShare.ReadWrite);
}
private void C()
{ 
   this.stream = File.Open(path, FileMode.Open, FileAccess.Read, FileShare.ReadWrite);
}
5
  • 動作がもうすこし具体的に検証できるようなソースコードを添付していただくことはできますか? Commented 2015年1月23日 5:14
  • おおまかなソースを載せました。 分かりづらかったら申し訳ありません。 Commented 2015年1月23日 5:56
  • いえ、対応ありがとうございます。問題を明確にするには十分です。 Commented 2015年1月23日 5:56
  • 1
    this.streamは、共有できません。BかCどちらかのインスタンスが設定されます。しかもリソースを解放できておらず、リソースリークの危険性があります。この程度のスレッドに生スレッドの使用は避けるべきで、Taskもしくは、非同期メソッドをの使用を検討すべきです。
    – PITA
    Commented 2015年1月23日 6:00
  • >BかCどちらかのインスタンスが設定される。→ 常に新しいインスタンスを設定し続ける必要があるので、リソースの開放をせずに上書きという手段を取っており、readerは定期的にその時点の最新のインスタンスを取得するという方法で実装しています。 やはりインスタンスは使用後に毎回closeした方が良いでしょうか? taskの実装に切り替えてみます。 ありがとうございます。 Commented 2015年1月23日 6:15

3 件の回答 3

3

BinaryReader/BinaryWriterともにスレッドセーフでは、ありません。

AとBのスレッドがあるとして、
ABABABABAB…のような動作は、保証されません。 
ABBAABBBAA…のように順不同になります。
つまり、処理の順番は、保証されません。

場合によっては、何らかの遅延、タイミングでデータが存在しない場合もありえます。
このような問題を解決するには、適切に排他制御を行うことです。

1
  • もっと細かく排他制御を行っていくしかないですよね。 改めてソースを見直して改善したいと思います。 返答ありがとうございます。 Commented 2015年1月23日 5:57
2

スレッドに関しては、別の方が回答なさってるので、別の見地から

交互にストリームを生成・上書

と記述されておりますが、読み取り位置と書き出しの位置の調停をされておりますでしょうか?
ストリームに追記していくのであれば、先のスレッドの動作順の問題を別にすれば問題は発生しないかもしれませんが、既存領域にランダムアクセスするのであれば、問題になるかもしれません。

2

同時書込の回避方法などは別の方にお任せするとして、率直にいうと、まず質問で意図しようとしている動作が、コードに落とされていないと感じました。そこからエラーの原因が分からなくなっていったのではないかと思います。ですので、少し整えることをして、一部回答とさせてください。

以下「読みだしに限った」コードで、できるだけ質問のコードを残しつつ、意図に沿う動きを目指しています。手元に環境がなくエアプログラミングになっているので、コンパイル通らなかったらごめんなさい。

using System;
using System.IO;
using System.Threading;

public class Test
{
    public static void Main() {
        new Test().startReaders();
    }

    private readonly string path = @"C:\tmp\test.txt";

    private bool isReadersRunning = false;

    public void startReaders() {
        if ( isReadersRunning)
            throw new InvalidOperationException();
        isReadersRunning = true;

        // スレッドB 生成・開始
        Thread thread_B = new Thread(new ThreadStart(B));
        thread_B.Start();

        // スレッドC 生成・開始
        Thread thread_C = new Thread(new ThreadStart(C));
        thread_C.Start();

        // メインは10秒後に終了処理を始める
        Thread.Sleep(10000);
        isReadersRunning = false;
    }

    private void B() {
        while (isReadersRunning) {
            System.Console.WriteLine("B Starts");
            try {
                using (FileStream stream = File.Open(path, FileMode.Open, FileAccess.Read, FileShare.ReadWrite))
                using (BinaryReader reader = new BinaryReader(stream)) {
                    // 読み取り処理
                    System.Console.WriteLine("File Being Read by B");
                }
            } catch (Exception e) {
                // ストリームが読み取れませんでした。
                Console.WriteLine(e.Message);
            }
            System.Console.WriteLine("B Ends");
            // 1秒まって続行
            Thread.Sleep(1000);
        }
    }

    private void C() {
        while (isReadersRunning) {
            System.Console.WriteLine("C Starts");
            try {
                using (FileStream stream = File.Open(path, FileMode.Open, FileAccess.Read, FileShare.ReadWrite))
                using (BinaryReader reader = new BinaryReader(stream)) {
                    // 読み取り処理
                    System.Console.WriteLine("File Being Read by C");
                }
            } catch (Exception e) {
                // ストリームが読み取れませんでした。
                Console.WriteLine(e.Message);
            }
            System.Console.WriteLine("C Ends");
            // 1秒まって続行
            Thread.Sleep(1000);
        }
    }
}
1
  • 私の説明不足な質問に、丁寧に返答をくださりありがとうございます。 このコードを参考に、改めて実装しなおしてみます。 Commented 2015年1月23日 8:14

この質問に回答するには、ログインする必要があります。

求めていた回答ではありませんか? のタグが付いた他の質問を参照する。