using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.Linq;using System.Text;using System.Threading;using System.Windows.Forms;using WindowsFormsApplication3.Enums;using WindowsFormsApplication3.DataStorge;using WindowsFormsApplication3.Jobs;using WindowsFormsApplication3.Jobs.Operation_System;namespace WindowsFormsApplication3.FormPage{    public partial class ThreadPoolTest : BaseWorkerForm    {        protected int finishedChildFormNO;        protected CheckoutStep checkoutStep;        void execute_StateChangeEvent(string strTipInfo, int Number, bool IsEnd)        {                     if (this.InvokeRequired)            {                this.BeginInvoke(new ExeCuteManager.DelArgInfo(DelPolfun), new object[] { strTipInfo, Number, IsEnd });            }            else            {                DelPolfun(strTipInfo, Number, IsEnd);            }        }        private void DelPolfun(string strTipInfo, int Number, bool IsEnd)        {            this.listBox.Items.Add(strTipInfo);            if (Number == 3 && IsEnd)            {                this.listBox.Items.Add(string.Format("所有的线程执行结束！"));            }        }        public ThreadPoolTest(CheckoutContext checkoutContext, CheckoutStep checkoutStep)            : base(checkoutContext, checkoutStep)        {            this.checkoutStep = checkoutStep;            InitializeComponent();            ResetForm();            backgroundWorker.DoWork += backgroundWorker_DoWork;            backgroundWorker.RunWorkerCompleted += backgroundWorker_RunWorkerCompleted;        }        private void backgroundWorker_DoWork(object sender, DoWorkEventArgs e)        {            bool isErrorFound = false;             foreach (BaseJob job in jobs)            {                job.StateChangeEvent += execute_StateChangeEvent;                WaitCallback callBack = new WaitCallback(job.Execute);                ThreadPool.QueueUserWorkItem(callBack, 1);                ThreadPool.QueueUserWorkItem(callBack, 2);                ThreadPool.QueueUserWorkItem(callBack, 3);                if (job.Status == JobStatus.Error)                {                    isErrorFound = true;                    checkoutContext.logData.Error(checkoutStep, "Job error");                }                status = isErrorFound ? FormStatus.Error : FormStatus.OK;                ReportStatusChanged();            }        }        private void backgroundWorker_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)        {            timer.Stop();            timer.Enabled = false;            RefreshForm();            ReportStatusChanged();            checkoutContext.logData.Finish(checkoutStep, "");        }        public override void Execute()        {            ReportStatusChanged();            checkoutContext.logData.Start(checkoutStep, "");            base.Execute();            backgroundWorker.RunWorkerAsync();        }        public override void ResetForm()        {            base.ResetForm();            jobs.Add(new ExeCuteManager(checkoutContext,checkoutStep));        }    }}