c# 多线程学习源码下载

【实例截图】

【核心代码】

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.Configuration;
using System.Threading;



namespace MutilThreadDemo.UI
{
    public partial class Form1 : Form
    {
        int i = 0;

        /// <summary>
        /// 判断是否在运行线程
        /// </summary>
        private static bool bRuning = false;

        /// <summary>
        /// 构造函数
        /// </summary>
        public Form1()
        {
            InitializeComponent();
        }

        #region 事件

        /// <summary>
        /// 窗体加载完成时事件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void Form1_Load(object sender, EventArgs e)
        {
            //使线程以非安全形式运行，允许在其它线程中调用主线程中界面控件
            ContainerControl.CheckForIllegalCrossThreadCalls = false;
        }
        /// <summary>
        /// 窗体关闭时事件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void Form1_FormClosing(object sender, FormClosingEventArgs e)
        {
            if (bRun == true)
            {
                MessageBox.Show("程序已经启动，请停止后再关闭程序！");
                e.Cancel = true;
            }
        }
        /// <summary>
        /// 启动程序按钮事件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void toolStripButton1_Click(object sender, EventArgs e)
        {
            if (bRuning == true)
            {
                MessageBox.Show("程序已经启动，请停止后再启动程序！");
            }
            else
            {
                bRuning = true;

                ThreadPoolIni(int.Parse(System.Configuration.ConfigurationManager.AppSettings["runthreads"]));
                ThreadStart();

                //显示状态信息

                this.toolStripStatusLabel1.Text = "程序已启动";
            }
        }
        /// <summary>
        /// 停止程序按钮事件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void toolStripButton2_Click(object sender, EventArgs e)
        {
            if (bRuning == false)
            {
                MessageBox.Show("程序已经停止！");
            }
            else
            {
                bRun = false;

                bRuning = false;

                this.toolStripStatusLabel1.Text = "程序已停止";
            }
        }
        /// <summary>
        /// 退出菜单按钮事件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void 退出XToolStripMenuItem_Click(object sender, EventArgs e)
        {
            this.Close();
        }

        #endregion

        #region 线程池
        /// <summary>
        /// 线程池
        /// </summary>
        private static List<Thread> threadPool = new List<Thread>();
        /// <summary>
        /// 判断是否运行线程，使用它来让线程自然终止
        /// </summary>
        static volatile bool bRun = false;

        /// <summary>
        /// 初始化线程池
        /// </summary>
        /// <param name="poolSize">线程池的大小</param>
        private void ThreadPoolIni(int poolSize)
        {
            threadPool.Clear();

            for (int i = 0; i < poolSize; i  )
            {
                Thread thread = new Thread(new ThreadStart(Work));
                thread.IsBackground = true;
                threadPool.Add(thread);
            }

            GC.Collect();
        }

        /// <summary>
        /// 启动线程池中的线程
        /// </summary>
        private void ThreadStart()
        {
            bRun = true;

            foreach (Thread thread in threadPool)
            {
                thread.Start();
            }
        }

        /// <summary>
        /// 停止线程池中的线程
        /// </summary>
        private void ThreadStop()
        {
            bRun = false;
        }

        /// <summary>
        /// 返回线程池大小
        /// </summary>
        /// <returns>线程池大小</returns>
        private int ThreadSize()
        {
            return threadPool.Count;
        }

        #endregion

        
        /// <summary>
        /// 线程工作的内容
        /// </summary>
        private void Work()
        {
            while (bRun)
            {
                //do something here

                this.label1.Text = i.ToString();

                i =1;


                //阻塞线程(必须的)，该时间在任务比较轻的时候能有效降低CPU占用率
                Thread.Sleep(10);
            }
        }

    }
}