微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

Task.Factory.StartNew的错误用法

同事写了这样一段代码

FactoryStartNew类:

using System;
 System.Collections.Generic;
 System.Linq;
 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>
        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 => {  o.Result; });
                bRst = va.Result;
                 bRst;
            }
            catch (System.Exception ex)
            {
                m_Log.Error(ex);
                return default(TResult);
            }
        }
    }
}
View Code

在WCF服务中使用:

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

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

 

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐