using System;

using System.Collections.Generic;

using System.IO;

using System.Linq;

using System.Text;

using System.Threading;

using System.Threading.Tasks;

namespace ConsoleApplication8

{

    /// <summary>

    /// 本文的任务是通过多线程在三个文件aa.txt,bb.txt,cc.txt全部写入文件，完成任务之后，

    /// 往ee.txt文件写入ok,之后主线程一直轮询去读取ee.txt该文件如果，里面出现ok，则往dd.txt写入内容，最后总任务完成之后删除临时文件ee.txt

    /// </summary>

    class Program

    {

        public static int i = ;

        static void Main(string[] args)

        {

            int[] aa = new int[] { , ,  };

            for (int i = ; i <=aa.Length; i++)

            {

                ParameterizedThreadStart ts = new ParameterizedThreadStart(ProcessData);

                Thread th = new Thread(ts);

                th.Start(i);

            }

            while (true)

            {

                string s = "";

                FileStream fs = null;

                try

                {

                     fs = new FileStream(@"C:\Users\yiwannuofu\Desktop\\ee.txt", FileMode.Open, FileAccess.Read, FileShare.Read);

                }

                ///如果刚好也有人在操作该文件的时候，指的是有另外一进程在操作该文件，

                /// 这里捕获异常继续尝试读取，直至成功，而对应的另一方或几方则睡眠500毫秒再尝试读取

                catch (Exception ex)

                {

                    Thread.Sleep(200);

                    continue;

                }

                byte[] b = new byte[fs.Length];

                fs.Read(b, , b.Length);

                fs.Flush();

                fs.Close();

                s = Encoding.UTF8.GetString(b);

                if (s.Contains("ok"))

                {

                    string BasePath = @"C:\Users\yiwannuofu\Desktop\dd.txt";

                    StreamWriter sw = new StreamWriter(BasePath);

                    for (int i=  ; i<=; i++)

                    {

                        sw.WriteLine(i);

                    }

                    sw.Close();

                    File.Delete(@"C:\Users\yiwannuofu\Desktop\\ee.txt");

                    break;

                }

            }

            Console.ReadKey();

        }

        private static void ProcessData(object obj)

        {

            int i = Convert.ToInt32(obj);

            string BasePath = @"C:\Users\yiwannuofu\Desktop";

            switch (i)

            {

                case :

                    BasePath += "\\aa.txt";

                    break;

                case :

                    BasePath += "\\bb.txt";

                    break;

                case :

                    BasePath += "\\cc.txt";

                    break;

            }

            lock(new object())

            {

                StreamWriter sw = new StreamWriter(BasePath);

                int start = (i - ) *  + ;

                int end = i * ;

                for (int j = start; j <= end; j++)

                {

                    sw.WriteLine(j);

                }

                sw.Close();

                i++;

                if (i >= )

                {

                    try

                    {

                        FileStream sw1 = new FileStream(@"C:\Users\yiwannuofu\Desktop\\ee.txt", FileMode.Create, FileAccess.ReadWrite, FileShare.ReadWrite);

                        byte[] bs = Encoding.UTF8.GetBytes("ok".ToCharArray());

                        sw1.Write(bs, , bs.Length);

                        sw1.Flush();

                        sw1.Close();

                    }

                    ///出现异常说明也有另外的进程在操作该文件，睡眠500毫秒，再试机写入内容

                    catch (Exception ex)

                    {

                        Thread.Sleep();

                    }

                }

            }

        }

    }

}