线程池ThreadPool实现异步多线程

ThreadPool线程池的主要方法：

1. public static Boolean QueueUserWorkItem(WaitCallback wc, Object state);

WaitCallback回调函数：通过将一些回调函数放入线程池中让其形成队列，然后线程池会自动创建或者复用线程去执行处理这些回调函数。State: 这个参数也是非常重要的，当执行带有参数的回调函数时，该参数会将引用传入，回调方法中，供其使用。

eg：用于文件处理：//删除ftp目录文件

DataTable dt = new ArchivesHelper().GetFileListByArchivesId(ID); //ftp文件

foreach (DataRow dr in dt.Rows)

{

          StateInfo sta = new StateInfo();

             sta.FtpPath = dr["filePath"].ToString();

             sta.FtpThumbnailPath = dr["Thumbnail"].ToString();

//hreadProc方法加入线程池中执行，sta对象传入回调函数，供ThreadProc方法使用

             ThreadPool.QueueUserWorkItem(new WaitCallback(ThreadProc), sta);

}

/// <summary>

        /// 创建一个委托来引用在辅助线程中执行的代码(接受一个对象参数并且没有返回值)

        /// </summary>

        /// <param name="stateInfo"></param>

        private void ThreadProc(Object stateInfo)

        {

            var sta = stateInfo as StateInfo;

            FtpHelper.DeleteFile(sta.FtpPath); //删除ftp文件

            FtpHelper.DeleteFile(sta.FtpThumbnailPath);//删除ftp缩略图

        }

巴特西

线程池ThreadPool实现异步多线程

最新文章

热门文章