threadpoolmanager_threadlocal是线程安全的吗

threadpoolmanager_threadlocal是线程安全的吗在WEB开发中,为了减少页面等待时间提高用户体验,我们往往会把一些浪费时间的操作放到新线程中在后台运行。简单的实现代码就是://代码一newThread(()=>{//dosomething}).Start();但是对于一个请求量大的网址这样做是很不现实的——每一个操作都要开启一个新线程,最终会因CPU不堪重负而使网站挂掉。更好的做法是使用线程队列。对于线程队列 ThreadPoo…

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE稳定放心使用

在WEB开发中,为了减少页面等待时间提高用户体验,我们往往会把一些浪费时间的操作放到新线程中在后台运行。

简单的实现代码就是:

//代码一
new Thread(()=>{
//do something
}).Start();

但是对于一个请求量大的网址这样做是很不现实的——每一个操作都要开启一个新线程,最终会因CPU不堪重负而使网站挂掉。

更好的做法是使用线程队列。

对于线程队列 ThreadPool.QueueUserWorkItem 很多人应该都不陌生,下边看微软的解释:

将方法排入队列以便执行,并指定包含该方法所用数据的对象。此方法在有线程池线程变得可用时执行。


它的作用就是将一些操作放入当前线程之外的另外一个线程中执行,它的使用方法很简单:

//代码二
ThreadPool.QueueUserWorkItem(stat => {
//do something
}, null);

它相对代码一的优点是会利用已经创建过的空闲的线程,如果没有空闲就排队,而不会盲目的一直创建下去。

但是它并没有摆脱“创建新线程”的问题:过多的线程会占用更多的资源。由此我们不难想到,我们为什么不自己搞个队列,让它们在同一个线程中逐个执行?对此,我写了个简单的实现类:

    public class BackgroundTasks
    {
        private class TaskEntity
        {
            public TaskEntity(Action<object> func, object data)
            {
                this.Function = func;
                this.Data = data;
            }
            public Action<object> Function;
            public object Data;
        }
        static Queue<TaskEntity> list = new Queue<TaskEntity>();
        
        static BackgroundTasks()
        {
            Thread th = new Thread(RunTask);
            th.IsBackground = true;
            th.Start();
        }
        static void RunTask()
        {
            while (true)
            {
                if (list.Count==0)
                {
                    Thread.Sleep(1000);
                }
                else
                {
                    TaskEntity entity;
                    lock (list)
                    {
                        entity = list.Dequeue();
                    }
                    try
                    {
                        entity.Function(entity.Data);
                    }
                    catch { }
                    Thread.Sleep(10);
                }
            }
        }

        public static void Add(Action<object> func, object data)
        {
            lock (list)
            {
                list.Enqueue(new TaskEntity(func, data));
            }
        }

    }

该类的使用很简单:

BackgroundTasks.Add((obj)=>{

Console.WriteLine(“这个任务的添加时间是:{0}”, obj as DateTime);

}, DateTime.Now);

还有一个“实例版”的,就是针对每个方法,分别创建一个任务队列:

    public class BackgroundTasks<T>
    {
        private Action<T> Function;

        private Queue<T> list = new Queue<T>();

        public BackgroundTasks(Action<T> func)
        {
            this.Function = func;

            Thread th = new Thread(RunTask);
            th.IsBackground = true;
            th.Start();
        }
        private void RunTask()
        {
            while (true)
            {
                if (list.Count == 0)
                {
                    Thread.Sleep(1000);
                }
                else
                {
                    T data;
                    lock (list)
                    {
                        data = list.Dequeue();
                    }
                    try
                    {
                        Function(data);
                    }
                    catch { }
                    Thread.Sleep(10);
                }
            }
        }

        public void Add(T data)
        {
            lock (list)
            {
                list.Enqueue(data);
            }
        }

    }

调用示例:

var bg = new BackgroundTasks<Blog>((blog) => { 
    Console.WriteLine(blog.BlogId); 
});
int i = 0;
while (i++ < 1000)
{
    bg.Add(new Blog() { BlogId = i });
}

这个设计既解决了异步执行,又解决了占用资源的问题。

但是世界上没有完美的东西,代码也是如此,由于队列中的任务是单线程执行,可能会导致某些任务在很长时间后才会被执行到,或者重启IIS导致很多任务还没有被执行就被丢弃。

无论怎么,这种设计还是适用于很多“一般情况”。

作者:朱会震

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

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/189800.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 报错: Failed to install the following Android SDK packages as some licences have not been accepted.

    报错: Failed to install the following Android SDK packages as some licences have not been accepted.导入已有的工程,在build时出现了FailedtoinstallthefollowingAndroidSDKpackagesassomelicenceshavenotbeenaccepted.从此开启有点漫长的脱坑之路。出现这个为在解决后发现主要是两个问题:一个是sdkmanager没有更新;另一个原因是项目配置…

  • awvs14安装教程_极品飞车14迅雷下载

    awvs14安装教程_极品飞车14迅雷下载Awvs14.1.210329187更新日期为2021年5月4日。首先卸载旧版awvs,然后重启电脑下载地址:Awvs14.1.210329187安装新版本运行AcunetixPremiumv14.2.210503151.exe。到如下填写登录的用户名和密码安装完后如下,此时没有激活激活安装完成后运行AcunetixPremiumActivationTool.exe进行激活,如下已经成功激活,然后改成中文版,如下,右上角点击保存既可以…

  • 网易社招面经,纯干货分享[通俗易懂]

    网易社招面经,纯干货分享[通俗易懂]个人背景本人毕业于二流一本大学非计算机相关专业,大三下学期开始学java。目前刚好工作两年,专业后端,base深圳。面试流程一面二面电话面三面四面视频面主管电话面hr电话面整个流程下来就

  • ubuntu20.04主题美化_ubuntu优化工具

    ubuntu20.04主题美化_ubuntu优化工具用了这么长时间ubuntu了,也该让自己的老婆漂亮点了。对吧。 于是搜之,找到资料记录一下: 资料链接:http://www.ubuntuhome.com/ubuntu-10-04-install-themes.html 主要步骤:添加ppa源,然后下载好看的主题,具体见资料链接。 记录一下添加源:首先打开终端并依次输入:sudoadd-apt-r…

  • VM虚拟机桥接模式无法联网解决办法

    VM虚拟机桥接模式无法联网解决办法1.背景介绍:桥接模式—-使虚拟机客户机可以和主机在同一网段,这样,和主机同局域网内的其他主机就也可以ping到虚拟机了;因此,虚拟机设置为桥接模式,且设为静态IP,这样以后就可以方便的使用虚拟机了;2.问题描述:桥接模式之前是好用的,但是主机有一天突然宕机了,重启之后,打开虚拟机,发现主机和虚拟机客户机相互之间ping不通;测试:a.将虚拟机IP获取方式改为自

  • 机器学习(十)Mean Shift 聚类算法

    机器学习(十)Mean Shift 聚类算法一、mean shift 算法理论Mean shift 算法是基于核密度估计的爬山算法,可用于聚类、图像分割、跟踪等,因为最近搞一个项目,涉及到这个算法的图像聚类实现,因此这里做下笔记。(1)均值漂移的基本形式给定d维空间的n个数据点集X,那么对于空间中的任意点x的mean shift向量基本形式可以表示为:这个向量就是漂移向量,其中Sk表示的是数据集的点到x的距离小于球半径h

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号