我们有一个C程序,根据用户配置的方式,可能是cpu绑定或IO绑定.为了与程序配置松散耦合,我希望我的线程池能够自动实现程序何时受益于更多线程(即cpu绑定).如果它意识到它是I / O限制并减少了工作人员的数量会很好,但这只会是一个奖励(即我会对自动增长而没有自动收缩的东西感到满意).

我们使用Boost,所以如果有什么东西可以帮助我们使用它.我意识到任何解决方案可能都是特定于平台的,因此我们主要对Windows和Linux感兴趣,对OS X或其他任何* nix都有兴趣.

解决方法

简短回答:对cpu密集型操作和IO使用不同的固定大小的线程池.除了池大小之外,有效线程数量的进一步调整将由有效缓冲区(生产者/消费者)完成,该缓冲区同步计算机和工作流的IO步骤.

对于计算和数据密集型问题,其中瓶颈是不同资源(例如cpu与IO)之间的移动目标,在线程和线程之间进行明确区分可能很有用,特别是作为第一个近似值:

>创建的线程使用更多cpu周期(“cpu线程”)
>为处理异步IO操作而创建的线程(“IO线程”)

更一般地说,线程应该根据它们所需的资源类型进行隔离.目标应该是确保单个线程不使用多个资源(例如,避免在读取数据和处理同一线程中的数据之间切换).当一个胎面使用多个资源时,它应该被拆分,并且两个结果线程应该通过有界缓冲区同步.

通常,应该有足够多的cpu线程来饱和系统上所有可用内核的指令流水线.为了确保这一点,只需要一个“cpu线程池”,其中只包含许多专用于计算工作的线程.如果可以信任,那将是boost ::或std :: thread :: hardware_concurrency().当应用程序需要更少时,cpu线程池中将只有未使用的线程.当它需要更多时,工作就会排队.您可以使用c 11 std :: async而不是“cpu线程池”,但您需要使用您选择的同步工具(例如计数信号量)来实现线程限制机制.

除了“cpu线程池”之外,还可以有另一个专用于异步IO操作的线程池(或其他几个线程池).在您的情况下,似乎IO资源争用可能是一个问题.如果是这种情况(例如本地硬盘驱动器),则应小心控制最大线程数(例如,本地硬盘驱动器上最多2个读取线程和2个写入线程).这在概念上与cpu线程相同,您应该有一个固定大小的线程池用于读取,另一个用于写入.不幸的是,可能没有任何好的原语来决定这些线程池的大小(虽然测量可能很简单,但是如果你的IO模式非常规则).如果资源争用不是问题(例如NAS或小HTTP请求),那么boost :: asio或c 11 std :: async可能是比线程池更好的选择;在这种情况下,线程限制可以完全留给有界缓冲区.

c – 如何根据程序的计算需求自动将线程添加到池中?的更多相关文章

  1. Realm Swift

    一旦带有主键的对象被添加到Realm之后,该对象的主键将不可修改。IgnoredProperties重写Object.ignoredProperties()可以防止Realm存储数据模型的某个属性。Realm将不会干涉这些属性的常规操作,它们将由成员变量提供支持,并且您能够轻易重写它们的setter和getter。所有的查询在Realm中都是延迟加载的,只有当属性被访问时,才能够读取相应的数据。

  2. android – 线程或服务

    我对android上的线程和服务感到困惑.如果我必须从服务器下载一些文件.它可能一次只有多个文件.在这种情况下,线程或服务应该选择什么?

  3. Android – 线程池策略和Loader可以用来实现吗?

    )>如果不是什么是创建AsyncTask池的好方法,是否可能正在实施它?

  4. Android图书馆的线程安全性

    我正在为Android系统实现一个本机共享库(.so).自然地,有一些代码块需要线程安全.我发现here的pthreads锁,互斥体或条件变量不受支持.我想知道图书馆层面通常使用什么来实现线程安全?解决方法这可以如何实现取决于您是否希望在Java级别线程访问时线程安全,或者需要将本机线程与Java线程同步.有两种方法只能同步Java级别的线程:最简单的方法是将synchronized关键字添加到多线程访问的本地方法中,即2.本机同步:请参考here关于如何同步Java线程的本机线程

  5. Node.js事件循环(Event Loop)和线程池详解

    这篇文章主要介绍了Node.js事件循环(Event Loop)和线程池详解,这篇文章比较浅显地探讨了有关事件循环的内部运作机制和技术细节,都是经过深思熟虑的,需要的朋友可以参考下

  6. Java实现手写乞丐版线程池的示例代码

    在这篇文章当中我们主要介绍实现一个非常简易版的线程池,深入的去理解其中的原理,麻雀虽小,五脏俱全,感兴趣的小伙伴快跟随小编一起学习学习吧

  7. java ThreadPoolExecutor线程池拒绝策略避坑

    这篇文章主要为大家介绍了java ThreadPoolExecutor拒绝策略避坑踩坑示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪

  8. Java线程池 ThreadPoolExecutor 详解

    这篇文章主要介绍了Java线程池 ThreadPoolExecutor,线程池包括线程集合、阻塞队列、拒绝策略处理器,更多相关内容需要的朋友可以参考一下

  9. 一篇文章带你搞懂Java线程池实现原理

    线程池无论是工作还是面试都是必备的技能,但是很多人对于线程池的实现原理却一知半解,并不了解线程池内部的工作原理,今天就带大家一块剖析线程池底层实现原理

  10. 详解Java线程池如何实现优雅退出

    这篇文章我们将从源码角度深度解析线程池是如何优雅的退出程序的,文中的示例代码讲解详细,对我们学习java线程池有一定帮助,需要的可以参考一下

随机推荐

  1. 从C到C#的zlib(如何将byte []转换为流并将流转换为byte [])

    我的任务是使用zlib解压缩数据包(已接收),然后使用算法从数据中生成图片好消息是我在C中有代码,但任务是在C#中完成C我正在尝试使用zlib.NET,但所有演示都有该代码进行解压缩(C#)我的问题:我不想在解压缩后保存文件,因为我必须使用C代码中显示的算法.如何将byte[]数组转换为类似于C#zlib代码中的流来解压缩数据然后如何将流转换回字节数组?

  2. 为什么C标准使用不确定的变量未定义?

    垃圾价值存储在哪里,为什么目的?解决方法由于效率原因,C选择不将变量初始化为某些自动值.为了初始化这些数据,必须添加指令.以下是一个例子:产生:虽然这段代码:产生:你可以看到,一个完整的额外的指令用来移动1到x.这对于嵌入式系统来说至关重要.

  3. 如何使用命名管道从c调用WCF方法?

    更新:通过协议here,我无法弄清楚未知的信封记录.我在网上找不到任何例子.原版的:我有以下WCF服务我输出添加5行,所以我知道服务器是否处理了请求与否.我有一个.NET客户端,我曾经测试这一切,一切正常工作预期.现在我想为这个做一个非托管的C客户端.我想出了如何得到管道的名称,并写信给它.我从here下载了协议我可以写信给管道,但我看不懂.每当我尝试读取它,我得到一个ERROR_broKEN_P

  4. “这”是否保证指向C中的对象的开始?

    我想使用fwrite将一个对象写入顺序文件.班级就像当我将一个对象写入文件时.我正在游荡,我可以使用fwrite(this,sizeof(int),2,fo)写入前两个整数.问题是:这是否保证指向对象数据的开始,即使对象的最开始可能存在虚拟表.所以上面的操作是安全的.解决方法这提供了对象的地址,这不一定是第一个成员的地址.唯一的例外是所谓的标准布局类型.从C11标准:(9.2/20)Apointe

  5. c – 编译单元之间共享的全局const对象

    当我声明并初始化一个const对象时.两个cpp文件包含此标头.和当我构建解决方案时,没有链接错误,你会得到什么如果g_Const是一个非const基本类型!PrintInUnit1()和PrintInUnit2()表明在两个编译单元中有两个独立的“g_Const”具有不同的地址,为什么?

  6. 什么是C名称查找在这里? (&GCC对吗?)

    为什么在第三个变体找到func,但是在实例化的时候,原始变体中不合格查找找不到func?解决方法一般规则是,任何不在模板定义上下文中的内容只能通过ADL来获取.换句话说,正常的不合格查找仅在模板定义上下文中执行.因为在定义中间语句时没有声明func,并且func不在与ns::type相关联的命名空间中,所以代码形式不正确.

  7. c – 在输出参数中使用auto

    有没有办法在这种情况下使用auto关键字:当然,不可能知道什么类型的.因此,解决方案应该是以某种方式将它们合并为一个句子.这可用吗?解决方法看起来您希望默认初始化给定函数期望作为参数的类型的对象.您无法使用auto执行此操作,但您可以编写一个特征来提取函数所需的类型,然后使用它来声明您的变量:然后你就像这样使用它:当然,只要你重载函数,这一切都会失败.

  8. 在C中说“推动一切浮动”的确定性方式

    鉴于我更喜欢将程序中的数字保留为int或任何内容,那么使用这些数字的浮点数等效的任意算术最方便的方法是什么?说,我有我想写通过将转换放在解析的运算符树叶中,无需将表达式转化为混乱是否可以使用C风格的宏?应该用新的类和重载操作符完成吗?解决方法这是一个非常复杂的表达.更好地给它一个名字:现在当您使用整数参数调用它时,由于参数的类型为double,因此使用常规的算术转换将参数转换为double用C11lambda……

  9. objective-c – 如何获取未知大小的NSArray的第一个X元素?

    在objectiveC中,我有一个NSArray,我们称之为NSArray*largeArray,我想要获得一个新的NSArray*smallArray,只有第一个x对象…

  10. c – Setprecision是混乱

    我只是想问一下setprecision,因为我有点困惑.这里是代码:其中x=以下:方程的左边是x的值.1.105=1.10应为1.111.115=1.11应为1.121.125=1.12应为1.131.135=1.14是正确的1.145=1.15也正确但如果x是:2.115=2.12是正确的2.125=2.12应为2.13所以为什么在一定的价值是正确的,但有时是错误的?请启发我谢谢解决方法没有理由期望使用浮点系统可以正确地表示您的帖子中的任何常量.因此,一旦将它们存储在一个双变量中,那么你所拥有的确切的一

返回
顶部