我在大学里对并行处理有所了解,现在我正努力在这方面做得更好。我可以编写可以并行运行的代码,然后启动线程,但之后我就失去了对线程执行的操作的控制。我想知道如何控制线程,例如将特定线程绑定(bind)到特定处理器内核。
我对 C++ 最感兴趣,但我已经用 Java 对此进行了一些编码,因此也欢迎那些答案。
最佳答案
与其他一些受访者的建议相反,对于某些系统(当然是高频交易,毫无疑问还有许多其他非常低延迟的系统,例如搜索引擎),将线程绑定(bind)到 CPU 核心(或超-线程核心,单个 CPU 线程)可以带来巨大的性能优势。
天真但越来越被拒绝的观点是,增加线程(在合理范围内)会增加此类系统的吞吐量。然而,越来越多的证据表明,如果设计得当,在大多数处理过程中使用极少线程的解决方案可能会大大优于高并发解决方案 - 有时是十倍甚至一百倍。
主要原因是上下文切换。上下文切换是一个 CPU 将当前线程的工作环境刷新到缓存 RAM(如果幸运的话)或主 RAM(如果不是)的过程,并读取下一个线程的工作环境 -它是低延迟系统可以执行的最昂贵的操作之一。
如果您希望在低延迟至为重要的情况下最大限度地减少上下文切换,则最好将某些关键进程限制在单个内核或 CPU 线程中。如果需要多个线程读取或写入由那些关键的线程限制进程管理的数据,您可能希望查看“Disruptor”模式,它使用环形缓冲区加上一些巧妙的技巧来允许非常快访问共享数据,同时几乎不需要对该数据进行独占锁定(链接如下)。
要在 Java 中以独立于操作系统的方式实现线程关联(CPU 绑定(bind))任务,您可以使用 Peter Lawrey 的 Java 线程关联库,链接如下。另请注意 Peter 将读取器线程绑定(bind)到超线程核心的一个超线程,并将写入器线程绑定(bind)到另一个超线程的示例,我认为这一技巧具有明显的好处(尽管我还没有尝试过)。
巴尼
http://lmax-exchange.github.io/disruptor/
https://github.com/peter-lawrey/Java-Thread-Affinity/wiki/How-it-works
关于java - 将特定线程绑定(bind)到特定处理器内核,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/3310959/
Rackup通过Rack的默认处理程序成功运行任何Rack应用程序。例如:classRackAppdefcall(environment)['200',{'Content-Type'=>'text/html'},["Helloworld"]]endendrunRackApp.new但是当最后一行更改为使用Rack的内置CGI处理程序时,rackup给出“NoMethodErrorat/undefinedmethod`call'fornil:NilClass”:Rack::Handler::CGI.runRackApp.newRack的其他内置处理程序也提出了同样的反对意见。例如Rack
它不等于主线程的binding,这个toplevel作用域是什么?此作用域与主线程中的binding有何不同?>ruby-e'putsTOPLEVEL_BINDING===binding'false 最佳答案 事实是,TOPLEVEL_BINDING始终引用Binding的预定义全局实例,而Kernel#binding创建的新实例>Binding每次封装当前执行上下文。在顶层,它们都包含相同的绑定(bind),但它们不是同一个对象,您无法使用==或===测试它们的绑定(bind)相等性。putsTOPLEVEL_BINDINGput
我真的很习惯使用Ruby编写以下代码:my_hash={}my_hash['test']=1Java中对应的数据结构是什么? 最佳答案 HashMapmap=newHashMap();map.put("test",1);我假设? 关于java-等价于Java中的RubyHash,我们在StackOverflow上找到一个类似的问题: https://stackoverflow.com/questions/22737685/
我收到这个错误:RuntimeError(自动加载常量Apps时检测到循环依赖当我使用多线程时。下面是我的代码。为什么会这样?我尝试多线程的原因是因为我正在编写一个HTML抓取应用程序。对Nokogiri::HTML(open())的调用是一个同步阻塞调用,需要1秒才能返回,我有100,000多个页面要访问,所以我试图运行多个线程来解决这个问题。有更好的方法吗?classToolsController0)app.website=array.join(',')putsapp.websiteelseapp.website="NONE"endapp.saveapps=Apps.order("
我正在尝试使用boilerpipe来自JRuby。我看过guide从JRuby调用Java,并成功地将它与另一个Java包一起使用,但无法弄清楚为什么同样的东西不能用于boilerpipe。我正在尝试基本上从JRuby中执行与此Java等效的操作:URLurl=newURL("http://www.example.com/some-location/index.html");Stringtext=ArticleExtractor.INSTANCE.getText(url);在JRuby中试过这个:require'java'url=java.net.URL.new("http://www
我只想对我一直在思考的这个问题有其他意见,例如我有classuser_controller和classuserclassUserattr_accessor:name,:usernameendclassUserController//dosomethingaboutanythingaboutusersend问题是我的User类中是否应该有逻辑user=User.newuser.do_something(user1)oritshouldbeuser_controller=UserController.newuser_controller.do_something(user1,user2)我
什么是ruby的rack或python的Java的wsgi?还有一个路由库。 最佳答案 来自Python标准PEP333:Bycontrast,althoughJavahasjustasmanywebapplicationframeworksavailable,Java's"servlet"APImakesitpossibleforapplicationswrittenwithanyJavawebapplicationframeworktoruninanywebserverthatsupportstheservletAPI.ht
这篇文章是继上一篇文章“Observability:从零开始创建Java微服务并监控它(一)”的续篇。在上一篇文章中,我们讲述了如何创建一个Javaweb应用,并使用Filebeat来收集应用所生成的日志。在今天的文章中,我来详述如何收集应用的指标,使用APM来监控应用并监督web服务的在线情况。源码可以在地址 https://github.com/liu-xiao-guo/java_observability 进行下载。摄入指标指标被视为可以随时更改的时间点值。当前请求的数量可以改变任何毫秒。你可能有1000个请求的峰值,然后一切都回到一个请求。这也意味着这些指标可能不准确,你还想提取最小/
HashMap中为什么引入红黑树,而不是AVL树呢1.概述开始学习这个知识点之前我们需要知道,在JDK1.8以及之前,针对HashMap有什么不同。JDK1.7的时候,HashMap的底层实现是数组+链表JDK1.8的时候,HashMap的底层实现是数组+链表+红黑树我们要思考一个问题,为什么要从链表转为红黑树呢。首先先让我们了解下链表有什么不好???2.链表上述的截图其实就是链表的结构,我们来看下链表的增删改查的时间复杂度增:因为链表不是线性结构,所以每次添加的时候,只需要移动一个节点,所以可以理解为复杂度是N(1)删:算法时间复杂度跟增保持一致查:既然是非线性结构,所以查询某一个节点的时候
我正在尝试在Rails上安装ruby,到目前为止一切都已安装,但是当我尝试使用rakedb:create创建数据库时,我收到一个奇怪的错误:dyld:lazysymbolbindingfailed:Symbolnotfound:_mysql_get_client_infoReferencedfrom:/Library/Ruby/Gems/1.8/gems/mysql2-0.3.11/lib/mysql2/mysql2.bundleExpectedin:flatnamespacedyld:Symbolnotfound:_mysql_get_client_infoReferencedf