一个Task.Factory.StartNew的错误用法

  • A+
所属分类:.NET技术
摘要

同事写了这样一段代码:FactoryStartNew类:在WCF服务中使用:我认为这个代码是错误的:当StartNewThread这个方法执行一个耗时的操作时,在执行操作的时间内,子线程在执行耗时操作,调用线程即父线程在阻塞(因为这句代码:bRst = va.Result;),这样在执行操作这段时间内,长时间占用了两个线程,多占用了一个线程。而且这个方法被写成了同步方法,而不是一个异步方法。WCF服务端所有方法都用StartNewThread方法包装一下,会导致多使用一倍的线程来处理同样多的请求。

同事写了这样一段代码:

FactoryStartNew类:

一个Task.Factory.StartNew的错误用法一个Task.Factory.StartNew的错误用法

using System; using System.Collections.Generic; using System.Linq; using System.Text;  namespace SunCreate.Common.ComLib {     /// <summary>     /// 2018-12-19  (勿修改其中代码)     /// </summary>     public class FactoryStartNew     {         private static log4net.ILog m_Log = log4net.LogManager.GetLogger(typeof(FactoryStartNew));          /// <summary>         /// 通过线程运行函数         /// </summary>         /// <typeparam name="TResult">返回值类型</typeparam>         /// <param name="action">运行函数</param>         /// <returns>返回值</returns>         public static TResult StartNewThread<TResult>(Func<TResult> action)         {             try             {                 TResult bRst;                 System.Threading.Tasks.Task<TResult> va = System.Threading.Tasks.Task.Factory.StartNew<TResult>(() =>                 {                     return action();                 })                 .ContinueWith<TResult>(o => { return o.Result; });                 bRst = va.Result;                 return bRst;             }             catch (System.Exception ex)             {                 m_Log.Error(ex);                 return default(TResult);             }         }     } }

View Code

在WCF服务中使用:

一个Task.Factory.StartNew的错误用法一个Task.Factory.StartNew的错误用法

public IList<VIPF_VIDEO_DEVICE> GetAllDevice() {     if (HI.Get<ISecurityImp>().CheckTicket())     {         return FactoryStartNew.StartNewThread<IList<VIPF_VIDEO_DEVICE>>(() => { return HI.Get<IBaseDataImp>().GetAllDevice(); });     }     return new List<VIPF_VIDEO_DEVICE>(); }

View Code

我认为这个代码是错误的:当StartNewThread这个方法执行一个耗时的操作时,在执行操作的时间内,子线程在执行耗时操作,调用线程即父线程在阻塞(因为这句代码:bRst = va.Result;),这样在执行操作这段时间内,长时间占用了两个线程,多占用了一个线程。而且这个方法被写成了同步方法,而不是一个异步方法。WCF服务端所有方法都用StartNewThread方法包装一下,会导致多使用一倍的线程来处理同样多的请求。

跟同事说过多次,但同事至今认为他的方法没有问题他对Task的理解没有错,所以我打算把这个随笔发到博客园,看看评论中能否有简捷清晰的描述,让同事明白这个问题,或者,我的理解是错的。

我比较执着,虽然能够容忍项目中有不好的代码,但是无法容忍如此重要的代码存在错误。