使用多线程异步创建一组文件

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.IO;
using System.Diagnostics;
namespace ThreadAppDemo
{
//mock data
class Friend
{
public string name { get; set; }
public string gender { get; set; }
public int age { get; set; }

public static List<Friend> FriendList()
{
return new List<Friend>()
{
new Friend() {name ="aa",gender ="boy",age =24},
new Friend() {name ="bb",gender ="girl",age =22},
new Friend() {name ="cc",gender ="boy",age =23},
new Friend() {name ="dd",gender ="boy",age =25}
,new Friend() {name ="ee",gender ="girl",age =20},
new Friend() {name ="ff",gender ="boy",age =21}
,new Friend() {name ="gg",gender ="girl",age =26},
new Friend() {name ="hh",gender ="girl",age =26}
,new Friend() {name ="ll",gender ="girl",age =26},
new Friend() {name ="mm",gender ="girl",age =26},
new Friend() {name ="nn",gender ="boy",age =26}
,new Friend() {name ="ii",gender ="girl",age =26},
new Friend() {name ="jj",gender ="girl",age =26},
new Friend() {name ="kk",gender ="girl",age =26},
new Friend() {name ="oogg",gender ="girl",age =26},
new Friend() {name ="oo",gender ="girl",age =26},
new Friend() {name ="ppqq",gender ="girl",age =24},
new Friend() {name ="qq",gender ="girl",age =20},
new Friend() {name ="xxx",gender ="girl",age =21},
new Friend() {name ="yy",gender ="girl",age =23},
new Friend() {name ="z",gender ="girl",age =26},
new Friend() {name ="zz",gender ="girl",age =22},
new Friend() {name ="1aa",gender ="boy",age =24},
new Friend() {name ="b1b",gender ="girl",age =22},
new Friend() {name ="cc1",gender ="boy",age =23},
new Friend() {name ="dd2",gender ="boy",age =25}
,new Friend() {name ="1ee",gender ="girl",age =20},
new Friend() {name ="ff1",gender ="boy",age =21}
,new Friend() {name ="1gg",gender ="girl",age =26},
new Friend() {name ="2hh",gender ="girl",age =26}
,new Friend() {name ="3ll",gender ="girl",age =26},
new Friend() {name ="4mm",gender ="girl",age =26},
new Friend() {name ="4nn",gender ="boy",age =26}
,new Friend() {name ="6ii",gender ="girl",age =26},
new Friend() {name ="1jj",gender ="girl",age =26},
new Friend() {name ="k1k",gender ="girl",age =26},
new Friend() {name ="o2ogg",gender ="girl",age =26},
new Friend() {name ="o1o",gender ="girl",age =26},
new Friend() {name ="pp1qq",gender ="girl",age =24},
new Friend() {name ="qq1",gender ="girl",age =20},
new Friend() {name ="1xxx",gender ="girl",age =21},
new Friend() {name ="1yy",gender ="girl",age =23},
new Friend() {name ="z1",gender ="girl",age =26},
new Friend() {name ="1zz",gender ="girl",age =22}
};
}

}
//使用多线程异步的创建一组文件
class WaitAllDemo
{
//define thread counts
const int threadNumber = 5;
static void Main()
{
string dir = @"E:\File";

if (!Directory.Exists(dir))
{
Directory.CreateDirectory(dir);
}

ManualResetEvent[] manualResetEvent = new ManualResetEvent[threadNumber];

Stopwatch watch = new Stopwatch();
watch.Start();
long startTime = Stopwatch.GetTimestamp();

for (int i = 0; i < threadNumber; i++)
{
manualResetEvent[i] = new ManualResetEvent(false);

FileState state = new FileState()
{
filePathName = dir,
manualResetEvent = manualResetEvent[i]
};

Thread thread = new Thread(new ParameterizedThreadStart(Writer.WriteFile));
thread.Name = string.Concat("thread", i + 1);
thread.Start(state);
//以下能够用线程池取代
// ThreadPool.QueueUserWorkItem(Writer.WriteFile, state);
}

//当全部的事件都收到信号。WaitALL返回true,主线程開始运行
WaitHandle.WaitAll(manualResetEvent);
watch.Stop();
Console.WriteLine("运行此操作耗时:{0}毫秒", (Stopwatch.GetTimestamp() - startTime) / (Stopwatch.Frequency / 1000));

Console.WriteLine("创建完成，主线程退出");

}

}
class FileState
{
public string filePathName { get; set; }
public ManualResetEvent manualResetEvent { get; set; }
}
class Writer
{
private static List<Friend> friends = Friend.FriendList();

public static void WriteFile(object obj)
{

FileState state = (FileState)obj;
string filePath = null;
string fileName = null;
//遍历全部数据，创建文件
while (friends.Count > 0)
{
lock (friends)
{
if (friends.Count > 0)
{
Friend friend = friends.First();

fileName = friend.name;
filePath = string.Concat(state.filePathName, @"\test", fileName, ".txt");

byte[] byteArray = Encoding.ASCII.GetBytes(string.Format("Name:{0},Gender:{1},Age:{2}", friend.name, friend.gender, friend.age).ToString());

Console.WriteLine("Start Work Item,FileName:{0},ThreadName:{1}", fileName,Thread.CurrentThread.Name);

FileStream file = null;
try
{
file = new FileStream(filePath, FileMode.Create);
file.Write(byteArray, 0, byteArray.Length);
}
finally
{
if (file != null)
{
file.Close();
}

Console.WriteLine("End Work Item,FileName:{0},ThreadName:{1}",  fileName, Thread.CurrentThread.Name);
}

friends.Remove(friends.First());
}

}

}
//当数据处理完成，调用Set方法,把事件状态更新为收到信号
state.manualResetEvent.Set();

}
}
}