C# と VB.NET の質問掲示板

■No83308 (金尾 さん) に返信
> ありがとうございます。
> 
> 試してみたのですが逆に10%程度ですが、更に遅くなってしまいました。
> 
> 
> 
>                 Dim fs As New FileStream(StrPath(i), FileMode.Open, FileAccess.Read)
> 
>             SyncLock fs
> 
>                 fs.Read(bs, 0, file_size)
>                 fs.Close()
> 
> 
>             End SyncLock
> 
> 
> という場所をロックしたのですが
> 場所は合っていますでしょうか？

場所も方法も間違っています。
こんな感じ

Dim LockObj As New Object
Parallel.For(略
	Dim bs() As Byte
	SyncLock LockObj //二重侵入を禁止
		Dim fs As New FileStream(StrPath(i), FileMode.Open, FileAccess.Read)
		fs.Read(bs, 0, file_size)
		fs.Close()
	End SyncLock

	//bsを文字列配列に変換して処理

携帯から手打ちしかできない状態なので多分ミスはあると思いますが、例えばおおむねこんな感じ

Dim count As New CountDownEvent(filePaths.Length)

' これがいわゆるブロッキングキュー
Dim queue As New BlockingCollection(Of Byte())()
Dim maxBuffers = 10
Dim bufferCount = 0

For Each filePath In filePaths
    Dim buff As Byte() = Nothing
    If bufferCount < maxBuffers Then
        If Not queue.TryTake(buff) Then
            ' 最大数まで作成してなくて空きがないなら新規作成
            buff = New Byte(fileLength - 1){}
            bufferCount += 1
        End If
    Else
        ' 最大数まで作成済みならバッファ空くまで待機
        buff = queue.Take()
    End If

    ' buffにファイル読み込み

    Task.Factory.StartNew(
        Sub()
            ' buffの処理

            ' 処理の終わりを通知してバッファをキューに戻す
            count.Signal()
            queue.Add(buff)
        End Sub
End For

' タスクが全部完了するまで待機
count.Wait()

ちょっとミスを見つけたため修正。

Forの終わりをNextに直したのと、End Sub の後に)つけたの、あと一応CountdownEventの大文字小文字修正。

あと、ファイルオープン位置はもっと前にする方が良いかもしれないのでコメント追加。

Dim count As New CountdownEvent(filePaths.Length)

' これがいわゆるブロッキングキュー
Dim queue As New BlockingCollection(Of Byte())()
Dim maxBuffers = 10
Dim bufferCount = 0

For Each filePath In filePaths
    ' ファイルのオープンはここの方がいいかも（オープンのみ）

    Dim buff As Byte() = Nothing
    If bufferCount < maxBuffers Then
        If Not queue.TryTake(buff) Then
            ' 最大数まで作成してなくて空きがないなら新規作成
            buff = New Byte(fileLength - 1){}
            bufferCount += 1
        End If
    Else
        ' 最大数まで作成済みならバッファ空くまで待機
        buff = queue.Take()
    End If

    ' buffにファイル読み込み

    Task.Factory.StartNew(
        Sub()
            ' buffの処理

            ' 処理の終わりを通知してバッファをキューに戻す
            count.Signal()
            queue.Add(buff)
        End Sub)
Next

' タスクが全部完了するまで待機
count.Wait()