草庐IT

【JavaEE】线程池

全部标签

c++ - 测试静态局部对象的初始化是否线程安全

我正在尝试编写一个测试(不检查汇编代码)来查看某个编译器是否符合c++11标准关于静态局部对象初始化的线程安全要求。到目前为止,我只能想出非确定性方法(在一个线程上休眠足够长的时间以使其可能(但不确定,问题!)另一个线程已经运行到某个执行点).有没有办法确定性地做到这一点? 最佳答案 例如像这样的syncvoodoo(见评论):#include#include#include#includestd::mutexg_mutex;conststd::chrono::secondsg_dura(1);voidlog(constchar*m

c++ - 从基于线程的流水线转移到基于任务的并行? (C++)

我正在研究如何将一些现有的C++代码从基于线程的并行性迁移到基于任务的并行性,以及这种迁移是否可取。这是我的场景:假设我有一些函数要在某个事件上执行。假设我有一台相机,每次到达一帧时我都想做一些繁重的处理并保存结果。一些处理是串行的,所以如果我只是在同一个线程中串行处理每一帧,我就无法获得完整的CPU使用率。假设帧每33毫秒到达一次,并且帧的处理延迟接近100毫秒。因此,在我当前的实现中,我创建了3个处理帧的线程,并以循环方式将每个新帧分配给其中一个工作线程。所以线程T0可能会处理帧F0、F3、F6等。现在我得到了充分的CPU使用率,我不必丢帧来保持实时速率。由于处理需要各种大的、临时

多线程批量同步数据到ES

需求背景:新增了ES,现在要讲数据库某张表的数据同步到ES中,百万级的数据量一次性读取同步肯定不行,所以可以用多线程同步执行同步数据。1.线程池配置类@ConfigurationpublicclassThreadPoolConfig{/***核心线程池大小*/privatestaticfinalintCORE_POOL_SIZE=17;/***最大可创建的线程数*/privatestaticfinalintMAX_POOL_SIZE=50;/***队列最大长度*/privatestaticfinalintQUEUE_CAPACITY=1000;/***线程池维护线程所允许的空闲时间*/priv

C++ 独立数据的多线程性能

让我们创建一个只有一个数据成员的非常简单的C++类:classContainer{public:std::vectorelements;Container(intelemCount);};现在创建N个线程来完成一个非常简单的任务:创建一个具有特定vector大小的本地Container遍历vector并简单地增加每个元素的val重复步骤210.000次(以秒而不是毫秒为单位获取时间)完整的代码list可以在Pastebin上找到根据CoreInfo我的CPU(IntelCorei52400)有4个内核,每个内核都有自己的L1/L2缓存:LogicaltoPhysicalProcesso

c++ - Clang线程安全分析和线程角色

clang线程安全分析docs和paper暗示可以指示特定函数仅由特定线程调用。来自论文:#include"ThreadRole.h"ThreadRoleInputThread;ThreadRoleGUIThread;classWidget{public:virtualvoidonClick()REQUIRES(InputThread);virtualvoiddraw()REQUIRES(GUIThread);};classButton:publicWidget{public:voidonClick()override{depressed=true;draw();//WARNING!}

c++ - 父不等待工作线程完成任务

在我的程序中,主线程创建了4个(或更多)工作线程。在某些时候,父线程(主线程)必须等待worker才能完成一些计算。线程在无限循环中运行,所以我不能使用pthread_join(..,..)POSIX函数来等待工作人员完成。所以我使用了一个全局计数器和一个条件变量。主线程代码unsignedjobs=0;//globalvariable//globalmutexandcv.Theygetinitialisedinmymain.pthread_mutex_tcounter_mutex;pthread_cond_tcounter_cv;staticvoidprocess(..){jobs=

c++ - 使用条件变量(监视器)同步线程

我需要同步多个线程(使用POSIX线程)。此外,我正在使用条件变量(监视器)来实现这一点。问题是我必须实现“先到先得”的策略。假设多个线程正在等待另一个线程发出条件变化的信号,pthread_cond_wait是否调用将线程本身放入队列中,还是我应该定义一个显式队列来实现这一点?一个可能的解决方案也可能是使用锁。 最佳答案 PthreadsAPI不保证pthread_cond_wait+pthread_cond_signal/pthread_cond_broadcast组合的公平性。spec明确指出调度策略将决定等待线程唤醒的顺序:

c++ - std::future 或 std::shared_future 等待多线程

我有一个线程从容器中获取每个元素并向数据库发送上传请求。上传是同步完成的。容器中的元素是金融合约,它们可能有也可能没有与之关联的数据结构调用ticktable。现在,对于那些有ticktable的合约,我必须进行两次上传。1)首先将ticktable上传到db。db返回一个id。2)将id附加到契约(Contract)上,然后上传契约(Contract)。因此,例如,如果我循环遍历包含100个合约的容器,假设其中30个具有ticktable,其余70个没有。我想弄清楚std::future或std::shared_future是否适合这样的任务?我尝试通过将future与30个合约中的

c++ - 跨内核线程迁移后是否可以强制重新加载 thread_local 变量?

我在内核和线程之上实现用户线程并观察到,当用户线程在内核线程之间迁移时,thread_local变量会从先前的内核位置读取,即使变量也被标记作为volatile。由于编译器仅将用户级swapcontext视为函数调用,因此下面的示例演示了简单函数调用的问题。#includestructFoo{intx;inty;};__threadFoo*volatilefoo;voidbar(){asm("nop");}voidf(){foo->x=5;bar();asmvolatile("":::"memory");//Wedesireasecondcomputationoftheaddresso

c++ - 从工作线程更新 QtCharts 的正确方法?

因为这是我的第一个问题,所以我想说StackOverflow帮助了我无数次。谢谢。现在是我的问题。我目前正在尝试在Qt5.8中实现一个简单的数据采集应用程序。该应用程序必须与DSP通信并以100Hz至10kHz的速率获取一些电压。由于我需要对获取的电压进行一些额外的计算,我认为在与GUI线程不同的线程中进行数据采集和操作是个好主意。数据采集和附加计算在单独的线程中工作得很好。我的问题是,使用QtCharts异步显示工作线程结果的正确方法是什么?如有任何建议,我们将不胜感激。最好的问候,T.Krastev 最佳答案 遇到了同样的问题。