異步寫入文件

Question

是否有任何方法可以編寫一個將數據重複寫入文件的異步函數。

我收到以下錯誤，當我寫異步函數

該進程無法訪問文件：因爲它正在被另一個進程使用

public void GoButton_Click(object sender, System.EventArgs e) 
{ 
    IAsyncResult ar = DoSomethingAsync(strURL, strInput); 
    Session["result"] = ar; 
    Response.Redirect("wait1.aspx"); 
} 

private IAsyncResult DoSomethingAsync(string strURL, string strInput) 
{ 
    DoSomethingDelegate doSomethingDelegate = new DoSomethingDelegate(DoSomething); 
    IAsyncResult ar = doSomethingDelegate.BeginInvoke(strURL, strInput, new AsyncCallback(MyCallback), null); 
    return ar; 
} 

private delegate void DoSomethingDelegate(string strURL, string strInput); 

private void MyCallback(IAsyncResult ar) 
{ 
    AsyncResult aResult = (AsyncResult)ar; 
    DoSomethingDelegate doSomethingDelegate = (DoSomethingDelegate)aResult.AsyncDelegate; 
    doSomethingDelegate.EndInvoke(ar); 
} 

private void DoSomething(string strURL, string strInput) 
{ 
    int i = 0; 
    for (i = 0; i < 1000; i++) 
    { 
     m_streamWriter.BaseStream.Seek(0, SeekOrigin.End); 
     m_streamWriter.WriteLine("{0} ", MethodCall(strURL, strInput)); 
     m_streamWriter.Flush(); 
     m_streamWriter.Close(); 
    } 
} 

Answer 1

那麼我有同樣的問題。現在解決它。這有點晚，但可能會對其他人有所幫助。

在下面的控制檯示例中包含以下使用語句。

using System; 
using System.Collections.Generic; 
using System.IO; 
using System.Text; 
using System.Threading.Tasks; 
Use of the FileStream Class 

下面的示例使用FileStream類，該類有一個選項，可以在操作系統級別發生異步I/O。在很多情況下，這將避免阻塞ThreadPool線程。要啓用此選項，您必須在構造函數調用中指定useAsync = true或options = FileOptions.Asynchronous參數。

如果通過指定文件路徑直接打開它們，StreamReader和StreamWriter不具有此選項。如果您向StreamReader/Writer提供由FileStream類打開的Stream，則StreamReader/Writer具有此選項。請注意，即使線程池線程被阻塞，異步仍可在UI應用程序中提供響應優勢，因爲UI線程在等待期間未被阻止。

書寫文字

以下示例將文本寫入文件。在每個等待聲明中，該方法立即退出。當文件I/O完成時，該方法在await語句後面的語句處繼續。請注意，async修飾符位於使用await語句的方法的定義中。

static void Main(string[] args) 
{ 
    ProcessWrite().Wait(); 
    Console.Write("Done "); 
    Console.ReadKey(); 
} 

static Task ProcessWrite() 
{ 
    string filePath = @"c:\temp2\temp2.txt"; 
    string text = "Hello World\r\n"; 

    return WriteTextAsync(filePath, text); 
} 

static async Task WriteTextAsync(string filePath, string text) 
{ 
    byte[] encodedText = Encoding.Unicode.GetBytes(text); 

    using (FileStream sourceStream = new FileStream(filePath, 
     FileMode.Append, FileAccess.Write, FileShare.None, 
     bufferSize: 4096, useAsync: true)) 
    { 
     await sourceStream.WriteAsync(encodedText, 0, encodedText.Length); 
    }; 
} 

讀取文本

下面的例子從文件中讀取文本。文本被緩衝，在這種情況下，被放置到一個StringBuilder中。與前面的例子不同，對await的評估產生了一個值。該ReadAsync方法返回一個任務，這樣的await的評估產生在操作完成後返回一個Int32值（numRead）..

static void Main(string[] args) 
{ 
    ProcessRead().Wait(); 
    Console.Write("Done "); 
    Console.ReadKey(); 
} 

static async Task ProcessRead() 
{ 
    string filePath = @"c:\temp2\temp2.txt"; 

    if (File.Exists(filePath) == false) 
    { 
     Console.WriteLine("file not found: " + filePath); 
    } 
    else { 
     try { 
      string text = await ReadTextAsync(filePath); 
      Console.WriteLine(text); 
     } 
     catch (Exception ex) 
     { 
      Console.WriteLine(ex.Message); 
     } 
    } 
} 

static async Task<string> ReadTextAsync(string filePath) 
{ 
    using (FileStream sourceStream = new FileStream(filePath, 
     FileMode.Open, FileAccess.Read, FileShare.Read, 
     bufferSize: 4096, useAsync: true)) 
    { 
     StringBuilder sb = new StringBuilder(); 

     byte[] buffer = new byte[0x1000]; 
     int numRead; 
     while ((numRead = await sourceStream.ReadAsync(buffer, 0, buffer.Length)) != 0) 
     { 
      string text = Encoding.Unicode.GetString(buffer, 0, numRead); 
      sb.Append(text); 
     } 

     return sb.ToString(); 
    } 
} 

您可以從Using Async for File Access

希望去看一下原始來源這有助於...

Answer 2

「C \ TEMP \ DATA.TXT」異步寫入文件不會解決此問題。您需要等待文件可用。

Answer 3

最終這取決於你爲什麼要這樣做。

如果您不打算將太多數據寫入文件，您可以不斷打開和關閉它。

或者，如果您知道何時需要打開文件，何時需要關閉文件，則可以在需要時打開文件，然後保持打開狀態，直到您知道該文件不再需要爲止。

Answer 4

幫助方法處理異步寫入文件的示例。

public async Task FileWriteAsync(string filePath, string messaage, bool append = true) 
    { 
     using (FileStream stream = new FileStream(filePath, append ? FileMode.Append : FileMode.Create, FileAccess.Write, FileShare.None, 4096, true)) 
     using (StreamWriter sw = new StreamWriter(stream)) 
     { 
      await sw.WriteLineAsync(messaage); 
     } 
    }