巧用ThreadPool.QueueUserWorkItem实现接口二次调用

Posted 2022-08-26 dotNET跨平台

背景

最近做了个项目有个接口涉及到批量计算的问题，耗时比较长。大家都知道，接口等待时间太长肯定是不可取的。那么只能做异步处理了；但是问题来了这个项目没有什么消息队列、redis之类的使用，本着怎么简单怎么来的思路，新搞个消息队列不现实；这时候，多线程派上用场。

再次遇到问题

于是噼里啪啦写了一顿，发现有个问题，我的方法涉及到很多ef core  数据库操作，在多线程的条件下，

报错如下:System.InvalidOperationException: A second operation was started on this context instance before a previous operation completed. This is usually caused by different threads concurrently using the same instance of DbContext. For more information on how to avoid threading issues with DbContext, see https://go.microsoft.com/fwlink/?linkid=2097913

生命周期为Scope方式，随着请求的结束，实例生命周期也会被释放，因此在多线程下若共享实例，容易出现实例已释放的错误，报错如下：Instances cannot be resolved and nested lifetimes cannot be created from this LifetimeScope as it (or one of its parent scopes) has already been disposed.Autofac   at Autofac.Core.Lifetime.LifetimeScope.BeginLifetimeScope(Object tag)。通过注入IServiceProvider，

就是这种方式也是不行的，还是需要改到原来的代码，还是违背初衷。

峰回路转

本来一筹莫展的，突然想到既然接口一次太慢了，那就分2次执行，第二次可以使用多线程触发，自己调用自己的耗时接口，这样就不需要改到原来的底层逻辑，要做的仅仅是把自己的方法拆分成2个。

1、请求一个异步方法，然后接口直接返回

/// <summary>
        /// 批量  添加  一级指标 数据（74.22分，全省第10名）
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("adminaddAreadatabatch")]
        public bool addAreadatabatch(List<AreadataDto> entity)
        
            //  foreach (var item in entity ?? new List<AreadataDto>())
            //  
            //   try
            //   
            _chartBll.Addbat(entity);
            //  
            //   catch (Exception ex)
            //  
            //     _logger.Error(ex);
            //  
            //  
`
            ThreadPool.QueueUserWorkItem(new WaitCallback(InsertNewsInfoExt), JsonConvert.SerializeObject(entity));`

            return true;
        

2、这里做一个http请求

private void InsertNewsInfoExt(object info)
        
            var client = new RestClient("http://xxxx/api/ningdeChart/updateAreadata");
            client.Timeout = -1;
            var request = new RestRequest(Method.POST);
            request.AddHeader("Content-Type", "application/json");
            var body = info.ToString();
            request.AddParameter("application/json", body, ParameterType.RequestBody);
            IRestResponse response = client.Execute(request);
            Console.WriteLine(response.Content);
        

3、在原来的接口adminaddAreadatabatch做下二次拆分，提供一个新的api

[HttpPost]
        [Route("updateAreadata")]
        public bool updateAreadata(List<AreadataDto> entity)
        
            foreach (var item in entity ?? new List<AreadataDto>())
            
                try
                
                    _logger.Info("updateAreadata");
                    _chartBll.updateAreadata(item.areaid, item.t1);
                
                catch (Exception ex)
                
                    _logger.Error(ex);
                
            
            return true;
        

问题得到解决。