flyinweb's blog

    在主线程启动一个新线程来进行拷贝，然后主线程订阅新线程的事件，并定义相关的处理方法来处理事件。

下面来说说功能实现的部分代码。
1、将用来拷贝文件的主要类：

  class DoWorks  
  {  
//定一个一个委托  
   public delegate void CopyFileHandler(long lngPosition, long LngCount);  
//定义一个事件（很重要），这个事件将被主线程捕捉，并对主线程的内容进行更改，比如：进度条。  
   public event CopyFileHandler CopyFileEvent;  
//定义两个字符串变量，sFile表示源文件，tFile表示目标文件，当然，这个可以使用属性的方式，这个为了简单明了，直接使用共有变量。  
   public System.String sFile;  
   public System.String tFile;  
 
   //这个就是工作线程使用到的方法了。  
   public void CopyFile()  
   {  
   //定义一个字节数组，用来缓存从源文件读到的字节流。  
    byte[] fb = new byte[2048];  
   //定义当前已读字节数，用于主线程更新界面。  
    long lngPosition = 0;  
    //源文件流  
    FileStream sfs = new FileStream(sFile,System.IO.FileMode.Open,System.IO.FileAccess.Read);  
   //二进制文件读取器  
    BinaryReader br = new BinaryReader(sfs);  
    br.BaseStream.Seek(0,System.IO.SeekOrigin.Begin);  
      
    if(File.Exists(tFile))  
     File.Delete(tFile);  
     //目标文件流  
     FileStream tfs = new FileStream(tFile,System.IO.FileMode.CreateNew,System.IO.FileAccess.Write);  
 
   //二进制文件写入器  
    BinaryWriter bw = new BinaryWriter(tfs);  
    //源文件的大小  
    long positionLength = sfs.Length;  
    int k = 10000;  
   //当读到的字节数小于2048，表示已经读到文件流的末尾了。停止读取  
    while(k>=2048)  
    {  
     k = br.Read(fb,0,fb.Length);  
 
     bw.Write(fb);  
 
     lngPosition += k;  
    //触发事件（关键），参数：1、表示当前共读取了多少，2、表示文件的长度       
     CopyFileEvent(lngPosition,positionLength);  
    }  
    tfs.Flush();  
    bw.Close();  
    br.Close();  
    tfs.Close();  
    sfs.Close();  
   }  
  } 

这个大家看看应该没有什么吧。下面我们就使用这个类来进行文件的拷贝
2、按钮的点击事件处理方法：

private void button1_Click(object sender, System.EventArgs e)  
{  
 DoWorks dw = new DoWorks();  
 //这两个公有变量一定要赋值，因为这次主要演示目的，一些判断及异常处理省略了。  
 dw.sFile = sourceFile;  
 dw.tFile = targetFile;  
 //这个是关键，定义事件的处理方法。  
 dw.CopyFileEvent += new AsyncCopyFile.Form1.DoWorks.CopyFileHandler(this.ChgProgress);  
 //定义新线程。  
 Thread t = new Thread(new ThreadStart(dw.CopyFile));  
 //启动线程  
 t.Start();  
} 

这里用到一个this.ChgProgress方法，这个方法就是用来处理界面的显示。
3、看一下事件处理方法：

private void ChgProgress(long k,long count)  
{  
 this.progressBar1.Maximum = (int)count;  
 this.progressBar1.Minimum = 0;  
 this.progressBar1.Value = (int)k;  
 this.label4.Text = count.ToString();  
 this.label2.Text = k.ToString();  
   
}