异步写入文件

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); 
     } 
    }