zoukankan      html  css  js  c++  java
  • c#读取并异步写入文件

    1.同步读取和写入

      StreamReader objReader = new StreamReader("E://workspace//zzz//read.txt", Encoding.GetEncoding("utf-8"));
                string sLine = "";
                ArrayList LineList = new ArrayList();
                while (sLine != null)
                {
                    sLine = objReader.ReadLine();
                    if (sLine != null && !sLine.Equals(""))
                        LineList.Add(sLine);
                }
                objReader.Close();
    
                string str = "";
                foreach (var item in LineList)
                {
                    str += item + Environment.NewLine;
                }
                string filePath = "E://workspace//zzz//" + DateTime.Now.Millisecond + ".txt";
                FileStream fs = new FileStream(filePath, FileMode.Create);
                StreamWriter sw = new StreamWriter(fs, Encoding.GetEncoding("utf-8"));
                //开始写入
                sw.Write(str);
                //清空缓冲区
                sw.Flush();
                //关闭流
                sw.Close();
                fs.Close();
    

      2.异步写入

     /// <summary>
            /// 异步将xml内容写入文件
            /// </summary>
            /// <param name="str"></param>
            /// <param name="encoding"></param>
            public static void XmlToFile(string str, string fileName, string encoding)
            {
                string filePath = "E://workspace_VS//zzz//" + fileName + DateTime.Now + ".xml";
                byte[] bytes = Encoding.GetEncoding(encoding).GetBytes(str.ToString());
                FileStream writer = new FileStream(filePath, FileMode.Create, FileAccess.Write);
                writer.BeginWrite(bytes, 0, str.Length, new AsyncCallback(endWrite), writer);
            }
            /// <summary>
            /// 结束异步写入
            /// </summary>
            /// <param name="asr"></param>
            private static void endWrite(IAsyncResult asr)
            {
                using (Stream str = (Stream)asr.AsyncState)
                {
                    str.EndWrite(asr);
                }
            }
    

      

  • 相关阅读:
    Linux 系统中用户切换(su user与 su
    linux 用户打开进程数和文件数调整
    hive sql 语法详解
    iOS
    iOS
    MySQL的事务的处理
    iOS
    iOS AOP编程思想及实践
    iOS 静态库和动态库(库详解)
    iOS 沙盒目录结构及正确使用
  • 原文地址:https://www.cnblogs.com/Leo_wl/p/13278465.html
Copyright © 2011-2022 走看看