Tag: 并发

并行字典正确使用

我正确地认为这是一个并行字典的正确使用 private ConcurrentDictionary<int,long> myDic = new ConcurrentDictionary<int,long>(); //Main thread at program startup for(int i = 0; i < 4; i++) { myDic.Add(i, 0); } //Seperate threads use this to update a value myDic[InputID] = newLongValue; 我没有锁等,只是更新字典中的值,即使多个线程可能会尝试做同样的事情。

java中volatile关键字最简单易懂的例子

我正在阅读关于Java中的volatile关键字,并完全理解它的理论部分。 但是,我正在寻找的是一个很好的例子,它显示了如果variables不是不稳定的,那么会发生什么。 下面的代码片段不能按预期工作( 来自aioobe ) class Test extends Thread { boolean keepRunning = true; public void run() { while (keepRunning) { } System.out.println("Thread terminated."); } public static void main(String[] args) throws InterruptedException { Test t = new Test(); t.start(); Thread.sleep(1000); t.keepRunning = false; System.out.println("keepRunning set to false."); } } 理想情况下,如果keepRunning不是易失性的,线程应该继续不断地运行。 但是,它几秒钟后停止。 我有两个基本的问题: 任何人都可以用例子解释volatile吗? 不符合JLS的理论。 挥发替代品是否同步? […]

如何从ConcurrentBag中删除所有项目?

如何清除ConcurrentBag ? 它没有任何方法像Clear或RemoveAll …

ConcurrentDictionary TryRemove何时会返回false

如果字典不包含给定键的值,还是会因为线程争用条件返回false而返回false,如另一个线程添加/更新的东西? 代码中的问题: ConcurrentDictionary<int, string> cd = new ConcurrentDictionary<int, string>(); // This might fail if another thread is adding with key value of 1. cd.TryAdd(1, "one"); // Will this ever fail if no other thread ever removes with the key value of 1? cd.TryRemove(1); 编辑:我认为它只会返回false,如果它不包含给定的键的值,但要绝对肯定。

Haskellmultithreading有多难?

我听说在Haskell中,创build一个multithreading应用程序就像使用一个标准的Haskell应用程序并使用-threaded标志编译它一样简单。 但是,其他情况下,在实际源代码中描述了使用par命令。 什么是Haskellmultithreading的状态? 引入程序有多简单? 是否有一个很好的multithreading教程,可以查看这些不同的命令及其用法?

Haskell轻量级线程开销并用于多核

我一直在阅读“真实世界Haskell”一书,关于并发性和并行性的一章。 我的问题如下: 由于Haskell线程真的只是一个“真正的”OS线程中的多个“虚拟”线程,这是否意味着创build很多(如1000)不会对性能产生严重影响? 也就是说,我们可以说用forkIO创build一个Haskell线程的开销(几乎)可以忽略不计? 如果可能,请带上切实的例子。 轻量级线程的概念不妨碍我们使用多核架构的好处吗? 据我所知,两个Haskell线程不可能同时在两个独立的内核上执行,因为从操作系统的angular度来看,它们确实是一个单一的线程。 还是Haskell运行时做了一些巧妙的技巧,以确保可以使用多个CPU?

Pure-Ruby并发哈希

实现一个可以在多个线程中修改的Hash的最佳方式是什么,但是锁的数量是最less的。 为了这个问题的目的,你可以假设哈希将是重读的。 它必须在所有Ruby实现中都是线程安全的,包括那些以真正同步的方式运行的实现,比如JRuby,它必须以纯Ruby(不允许C或Java)编写。 随意提交一个总是locking的天真的解决scheme,但这不可能是最好的解决scheme。 优雅的点,但较小的可能性locking胜过较小的代码。

你如何利用多核?

作为来自于企业Web开发领域的HPC世界中的一员,我总是好奇地看到,“真实世界”中的开发者如何利用并行计算。 现在所有的芯片都是多核的 ,这更加重要,而且芯片上有成千上万个核心,而不是几个核心,就更加相关。 我的问题是: 这是如何影响你的软件路线图的? 我特别感兴趣的是关于多核如何影响不同软件领域的真实故事,所以请说明在您的答案中( 例如服务器端,客户端应用程序,科学计算等)您做了什么样的开发。 您现有的代码如何利用多核机器,以及您面临的挑战是什么? 你使用的是OpenMP , Erlang , Haskell , CUDA , TBB , UPC还是其他的东西? 随着并发水平的不断提高,你打算做什么?你将如何处理数百或数千个内核? 如果你的域不容易受益于并行计算,那么解释为什么它也是有趣的。 最后,我把它定义为一个多核问题,但可以随意谈论其他types的并行计算。 如果您正在移植部分应用程序以使用MapReduce ,或者如果大型群集上的MPI是您的范例,那么您也一定要提及这一点。 更新:如果你的答案是#5,提到你是否认为事情会改变,如果有更多的核心(100,1000等),你可以提供可用的内存带宽(看到带宽越来越小,每个核心)。 你仍然可以使用你的应用程序的其余核心?

循环无锁缓冲区

我正在devise一个连接到一个或多个数据馈送stream的系统,并对数据进行一些分析,而不是基于结果触发事件。 在典型的multithreading生产者/消费者设置中,我将有多个生产者线程将数据放入一个队列,多个消费者线程读取数据,而消费者只对最新的数据点加上n个点感兴趣。 生产者线程将不得不阻止,如果缓慢的消费者无法跟上,当然消费者线程将阻止时,没有未经处理的更新。 使用读/写锁的典型并发队列可以很好地工作,但数据传入的速度可能很大,所以我想减less我的locking开销,尤其是制作者的locking锁。 我认为我需要一个循环的无锁缓冲区。 现在有两个问题: 循环锁无缓冲区的答案? 如果是这样,在我推出自己的之前,你知道任何符合我需要的公共实现吗? 任何实现循环无锁缓冲区的指针总是受欢迎的。 顺便说一句,在Linux上使用C ++来完成。 一些额外的信息: 响应时间对我的系统至关重要。 理想情况下,消费者线程将希望看到任何更新尽快进入,因为额外的1毫秒的延迟可能会使系统变得毫无价值,或价值更低。 我所倾向的devise思路是一个半无锁的循环缓冲区,其中生产者线程尽可能快地将数据放入缓冲区,让我们调用缓冲区A的头部,不阻塞,除非缓冲区满了, A满足缓冲区Z的结束。消费者线程将分别持有指向循环缓冲区P和P n的两个指针,其中P是线程的本地缓冲区头,P n是P之后的第n个项目。每个消费者线程将前进它的P和P n一旦完成处理当前的P,缓冲区指针Z的结束以最慢的P n前进。 当P赶上A,这意味着没有更多的新的更新处理,消费者旋转,并忙着等待A再次前进。 如果消费者线程旋转太久,它可以进入睡眠状态,并等待一个条件variables,但我可以消费者占用CPU周期等待更新,因为这不会增加我的延迟(我会有更多的CPU核心比线程)。 想象一下,你有一个循环轨道,生产者在一群消费者面前运行,关键是调整系统,使生产者通常跑在消费者的前面几步,这些操作大部分可以使用无锁技术完成。 我明白,要获得执行权的细节并不容易……好吧,非常辛苦,这就是为什么我想在从自己的angular度去学习别人的错误之前。

如何在Java中asynchronous调用一个方法

我最近一直在看Go的goroutine ,认为在Java中有类似的东西会很好。 就我所寻找的并行化方法调用的常见方式而言,就是做类似的事情: final String x = "somethingelse"; new Thread(new Runnable() { public void run() { x.matches("something"); } }).start(); 那不是很优雅。 有没有更好的方法来做到这一点? 我在一个项目中需要这样的解决scheme,所以我决定围绕asynchronous方法调用实现我自己的包装类。 我在J-Go上发布了我的包装类。 但是我不知道这是不是一个好的解决scheme。 用法很简单: SampleClass obj = … FutureResult<Integer> res = … Go go = new Go(obj); go.callLater(res, "intReturningMethod", 10); //10 is a Integer method parameter //… Do something else //… System.out.println("Result: "+res.get()); //Blocks […]