草庐IT

bulk-synchronous-parallel

全部标签

java - 为什么 synchronized 关键字在 Java 中称为 'synchronized' 而不是更精确的 'mutexed' ?

我听说在Java中选择使用“同步”一词来描述互斥语句是一个错误(编辑:“错误”在这里是一个错误的选择。请参阅编辑),但我想知道如果选择背后确实有原因。[编辑]受Safyan评论的启发,我想补充一点,同步是在线程之间建立计时关系的通用术语。它可以包括互斥和速率控制之类的东西(例如,两个线程以相同的速率做某事)。使用“synchronized”来表示互斥而不是使用更具体的关键字(如“mutexed”)似乎不必要地模棱两可。 最佳答案 这不是一个错误。意思就是它所说的;代码必须与其他线程同步以提供互斥。而且,事实上,术语同步可能比“互斥锁

java - 如何在没有同步块(synchronized block)(即低成本锁)的情况下在一个安全操作中原子地检查 Java 中的两个 AtomicBooleans?

所以我有两个AtomicBoolean,我需要检查它们。类似的东西:if(atomicBoolean1.get()==true&&atomicBoolean2.get()==false){//...}但两者之间存在竞争条件:(有没有办法将两个原子boolean检查组合成一个而不使用同步(即同步块(synchronizedblock))? 最佳答案 好吧,我可以想到几种方法,但这取决于您需要的功能。一种方法是“作弊”并使用AtomicMarkableReference:finalAtomicMarkableReferencetwoBo

Java 并行流 : how to wait for threads for a parallel stream to finish?

所以我有一个列表,我从中获取并行流来填充map,如下所示:Mapmap=newHashMap();Listlist=some_filled_list;//Puttingdatafromthelistintothemaplist.parallelStream().forEach(d->{TreeNodenode=newTreeNode(d);map.put(node.getId(),node);});//printoutmapmap.entrySet().stream().forEach(entry->{System.out.println("ProcessingnodewithID="

java - 同步块(synchronized block)中的更改何时对其他线程可见

假设我在同步方法中更新了两个变量的值。在退出同步块(synchronizedblock)之前是否有可能在同步方法中设置的新值对其他线程可见?publicsynchronizedvoidsetValues(){a=5;//assumethreadispreemptedafterthisassignment//wouldthevalue5bevisibletootherthreads?//myunderstandingisthatthevalueswillnotbeflushedto//mainmemoryuntilthelockisreleased-i.e.,untilthesynchr

java - 在处理 Java 8 流管道时,对 sequential() 和 parallel() 的调用顺序是否重要?

调用sequential()和parallel()是否会改变Java8流管道的执行方式?例如,假设我有这段代码:newArrayList().stream().parallel().filter(...).count();在此示例中,很明显filter()将并行运行。但是,如果我有这段代码怎么办:newArrayList().stream().filter(...).parallel().count();filter()仍然并行运行还是顺序运行?不清楚的原因是因为像filter()这样的中间操作是惰性的,即它们不会运行,直到调用像count()这样的终端操作。因此,在count()被调

java - AtomicReference 和 Synchronized 之间有什么区别?

AtomicReference和Synchronized有区别吗?例如publicclassInternet{AtomicReferenceaddress;publicStringgetAddress(){returnaddress.toString();}publicvoidsetAddress(Stringaddress){this.address.set(address);}}然后我将这个类传递给一些同时尝试使用这个类的线程,如果我使用这个是不是一样的:publicclassInternet{Stringaddress;publicStringgetAddress(){retur

java - "synchronized(this)"与 Java 中的 "synchronized((BaseClass)this)"?

这是我之前问题的后续问题,Isthisvariablebeingsafelyaccessedbyusingsynchronization?对于下面的程序,ClassSubClassBextendsSuperClassA{protectedintc;publicvoidinc(){synchronized(this){c++;}}publicvoiddec(){synchronized((SuperClassA)this){c--;}}}计数器“c”会被线程安全地访问吗?我不确定在“dec()”方法中,SuperClassA强制转换“this”是否引用了同步块(synchronizedb

c++ - 使用#pragma omp parallel 让程序变慢

我的C++程序大约需要300秒才能运行。在我的程序中,我需要cwis划分我的vector。VS分析器告诉我们这大约需要15%的运行时间。这是代码:templatemyVectorcWisDivide(myVector&vec1,myVector&vec2){try{if(vec1._rows==vec2._rows){myVectorresult(vec1._rows);//#pragmaompparallelforfor(intr=1;r这个函数被调用了很多次。如果我在循环之前使用#pragma...,CPU使用率会保持100%大约350秒。这比按顺序运行程序所花费的时间还多。如果有

c++ - #pragma omp parallel num_threads 不工作

#include#include#includevoidmain(intargc,int*argv[]){#pragmaompparallelnum_threads(3){inttid=omp_get_thread_num();printf("Helloworldfromthread=%d\n",tid);if(tid==0){intnthreads=omp_get_num_threads();printf("Numberofthreads=%d\n",nthreads);}}}我正在学习OpenMP,我不明白为什么我指定了线程数3,它只执行一个线程?程序输出:Helloworldfr

c++ - 在 C++AMP 的 parallel_for_each 中使用用户指定的函数

我目前正在编写一个库,我希望能够允许用户定义一个函数(声明为restrict(amp))并允许他们传递这个函数在concurrency::parallel_for_each循环中使用我的库函数之一。例如:templatevoidFoo(constconcurrency::array_view&avParam,Funcf){concurrency::arrayarrResult(avParam.extent);concurrency::parallel_for_each(avParam.extent,[=,&arrResult](concurrency::indexindex)restr