concurrent-programming相关内容

如何让 2 个 JVM 相互通信

我有以下情况: 我有 2 个 JVM 进程(实际上是 2 个 java 进程分别运行,而不是 2 个线程)在本地机器上运行.让我们称它们为 ProcessA 和 ProcessB. 我希望它们相互通信(交换数据)(例如,ProcessA 向 ProcessB 发送消息以执行某些操作). 现在,我通过编写一个临时文件来解决此问题,这些进程会定期扫描此文件以获取消息.我觉得这个解决方 ..
发布时间:2021-11-25 17:17:25 Java Web开发

React PHP如何处理异步非阻塞I/O?

React PHP如何处理异步非阻塞I/O? Nodejs使用其事件队列来处理不同线程上的I/O.它为此使用libuv.像在PHP中一样,React如何在单个线程上处理非阻塞I/O进程? 解决方案 React PHP提供了应用程序的主要事件循环.您仍然需要以非阻塞的方式编写代码,因为它们全部在一个线程上.所有可能的解决方案都围绕使用php而不是我确定大多数php开发人员习惯于使用ph ..
发布时间:2021-04-12 18:55:54 其他开发

在C / C ++中检查文件是否正在使用的方法?

有什么方法可以检查C / C ++中是否正在使用文件?还是我必须总是实施锁/信号灯以防止多个线程/进程同时访问任何文件? 如果我们考虑使用Linux ,以及以下情况:我想使用预先定义的通信框架,通过RS-232通信将存储在设备A中的文件内容分块传输到另一设备B。发送此传输请求时,我想在发送“ Ready to Transfer:OK”响应之前,确认设备A中的任何进程都没有使用该文件,然后我将 ..
发布时间:2020-10-07 21:45:19 其他开发

将ConcurrentBag设置为可通知状态是否安全?

我需要使ConcurrentBag明显。我需要知道那是安全的吗?该类的代码为 公共类NotifiableConcurrentBag :ConcurrentBag,INotifyCollectionChanged,其中T:类 { public NotifiableConcurrentBag() { dispatcher = Dispatcher.CurrentDispa ..
发布时间:2020-10-07 21:32:19 其他开发

Java 8:并行FOR循环

我听说Java 8提供了许多有关并发计算的实用程序.因此,我想知道并行化给定for循环的最简单方法是什么? public static void main(String[] args) { Set servers = getServers(); Map serverData = new ConcurrentHashMap() ..
发布时间:2020-06-26 23:54:25 其他开发

何时选择多线程或多处理?

我从未在并发编程上做过任何事情,我对它们的了解仅来自OS 图书. 我今天在一次采访中遇到了这个问题.我想知道是否有人可以给我一个直观的 关于多线程和多进程以及何时选择它们的说明.或者,也许可以 向我推荐一些书籍或带有实际示例的链接.我想阅读 的源代码 具有一致编程的开源项目(c/c ++),希望您可以推荐一个. 非常感谢您的帮助. 解决方案 多线程: 执行 ..
发布时间:2020-05-13 22:31:05 其他开发

锁定锁与非锁定锁

我在这里思考:如果您有2个线程执行需要同步的FAST操作,那么非阻塞方法不是比阻塞/上下文切换方法更快/更好的方法吗? 非阻塞性的意思是: while(true){ 如果(checkAndGetTheLock())中断; } 如果您有太多线程在锁中循环,我唯一想到的就是饥饿(CPU耗尽). 如何在一种方法与另一种方法之间取得平衡? 解决方案 这是实践中的Java并发 ..
发布时间:2020-05-13 21:37:53 其他开发

如何立即打印Python ThreadPoolExecutor.map的结果?

我正在为几组可迭代对象运行一个函数,所有过程完成后立即返回所有结果的列表. def fct(variable1, variable2): # do an operation that does not necessarily take the same amount of # time for different input variables and yields resul ..
发布时间:2020-05-05 13:58:56 其他开发

浏览器中的JavaScript是否可能发生并发读/写读/写冲突?

我有一种情况,我正在制作几个(比如四个)ajax调用(使用AngularJS http get,如果这很重要)我希望每次调用回调并增加一个计数器,这样我就可以知道什么时候全部(四个)线程已经完成。 我担心的是,因为JavaScript没有任何可与Java的“synchronized”或“volatile”关键字相媲美的东西,所以它可以用于多个并发线程在递增计数器时发生碰撞,从而错过了一些增量 ..
发布时间:2019-06-12 12:45:04 JavaScript

如何使用其他Java程序停止运行程序

我一直在实现一个程序来编译和运行其他应用程序。当我的应用程序发现存在问题时,我想知道是否有办法终止程序。无限循环。我试图使用process.Destroy()但它杀死了CMD而不是那个有无限循环的实际程序...... 非常感谢你的帮助。 以下是我的代码的一部分: synchronized(pro){ pro.wait(30000); } 试试{ pro.exitVa ..
发布时间:2018-12-22 18:58:55 Java相关

启动/暂停/恢复/暂停...由其他类调用的方法

我想实现一个Anytime k-NN分类器,但我找不到一种方法来调用“classify(...)”方法一段特定的时间,暂停它,在方法暂停之前获取可用的结果,恢复该方法一段特定的时间,暂停它,在方法暂停之前获得可用的结果,等等... 我使用数据结构来获得近似结果。当算法遍历数据结构时,它最终会遇到实际的训练数据向量。 public class AnytimeKNN { public in ..
发布时间:2018-12-22 18:54:23 Java相关

如何使用java并发编程的ExecutorService?

我使用下面的代码在远程服务器上上传图像。当我在下面使用时,它会在远程服务器上并行上传所有图像。 列表与LT;未来<字符串>> futureList = new ArrayList>(); ExecutorService execService = Executors.newFixedThreadPool(Images.size()); ..
发布时间:2018-12-19 23:47:57 Java相关

C / C ++和C#/ Java之间使用volatile的区别是什么?

我在许多参考文献中发现它提到C / C ++中的 volatile 很弱并且可能在多处理器的并发环境中引起问题,但它( volatile )可以用作C#/ Java中差异CPU之间的通信机制。看来这个关键字在C#/ Java中比在C / C ++中更严格,但它们之间的区别/影响是什么? 这是 C / C ++中的volatile 。 为什么不挥发在多线程C或C ++编程中被认为有用吗? ..
发布时间:2018-12-10 12:02:59 Java相关

Haskell,通道,STM,线程,消息传递

我试图使用通道/ STM来实现Haskell中的消息传递。也许这是一个可怕的想法,并且有更好的方式来实现/使用Haskell中的消息传递。如果是这样,请让我知道;然而,我的任务已经打开了关于并发Haskell的一些基本问题。 我听说过关于STM的很多东西,特别是Haskell中的实现。既然它支持阅读和写作,并且有一些安全方面的好处,我想有人会从那里开始。这引出了我最大的问题: msg ..
发布时间:2018-06-04 17:35:52 其他开发

Go编程语言相互并发执行

我有两个并发的例程如下, 例程1 { 例程过程 关键部分{ } 例行程序 } 例行2 { 例行程序 关键部分{ } 例行程序 } 是否有可能通过使用一些内置函数来实现关键部分? 解决方案 你的问题: 我有N个并发的go例程(或多或少有相同的用途)。每个人都有一个关键部分。在进入关键部分之前,每个例程都会做一些消息发送 ..
发布时间:2018-05-02 18:43:18 其他开发语言

所有的goroutines都睡着了 - 僵局! -------错误

我想写三个并发的去程序,将整数发送给对方。现在,我的代码被正确编译了,但是在第一次执行后,它给出错误“所有的goroutines都睡着了 - 死锁!”。我试图找到错误,但我无法找到代码逻辑中的任何错误。任何人都可以帮我找到我的代码中的错误。我的代码如下。 包主 导入“rand” func Routine1(command12 chan int,response12 chan int ..
发布时间:2018-05-02 18:00:57 其他开发语言

如何在Java并发中发生可见性问题?

我正在阅读的书:“Java并发实践”,以更好地了解java并发的工作原理。在第3章第3.1节:可见性有一个例子,在这本书试图显示如何可见性问题发生。下面是示例代码(本书中的代码3.1): public class NoVisibility { private静态布尔准备; private static int number; private static class Re ..
发布时间:2016-12-26 21:30:36 其他开发

如何同时修改向量

我必须确保迭代矢量;该向量没有更新,以避免 ConcurrentModificationException 。我可以使用并发收集。但我只是想试一试Vector。下面是我写的代码。 public class TestConcurrentModification1 { Vector a = new Vector public static void main(String [] ar ..
发布时间:2016-12-26 21:29:06 其他开发

相互并行Go程序中的死锁错误

我有三个并发的例程,如下所示: func Routine1(){ mutex1.Lock do something mutex2.Lock() mutex3.Lock() send int to routine 2 send int to routine 3 *打印东西* mutex2.Unlock() mutex3.Unlock() 接收ints ..
发布时间:2016-12-26 21:21:53 其他开发