Tag: 并发

从multithreading获取java.util.HashMap的值是否安全（不需要修改）？

有一种情况是地图将被构build，一旦它被初始化，它将不会再被修改。 然而，它将被访问（仅通过get（key））来自多个线程。 以这种方式使用java.util.HashMap是否安全？ （目前，我很高兴地使用java.util.concurrent.ConcurrentHashMap ，并没有任何需要提高性能的措施，但是只要简单的HashMap就足够了就可以了，所以这个问题不是 “我该用哪一个？ “这也不是一个performance问题，而是问题是”安全吗？“）

有多个进程共享侦听套接字的方法吗？

在套接字编程中，您将创build一个监听套接字，然后为每个连接的客户端获得一个普通的stream套接字，您可以使用它来处理客户端的请求。 OS在幕后pipe理传入连接的队列。 两个进程无法同时绑定到相同的端口 – 默认情况下，无论如何。 我想知道是否有一种方法（在任何知名的操作系统，尤其是Windows上）启动一个进程的多个实例，以便它们都绑定到套接字上，因此它们有效地共享队列。 每个stream程实例可以是单线程的; 它只会在接受新的连接时被阻塞。 当一个客户端连接时，其中一个空闲进程实例将接受该客户端。 这将允许每个进程都有一个非常简单的单线程实现，除非通过显式的共享内存，否则就不会共享，用户可以通过启动更多的实例来调整处理带宽。 这样的function是否存在？ 编辑：对于那些问“为什么不使用线程？” 显然线程是一个选项。 但是在一个进程中有多个线程，所有对象都是可共享的，而且必须非常小心，以确保对象不是共享的，或者一次只能看到一个线程，或者是绝对不变的，最stream行的语言和运行时缺乏pipe理这种复杂性的内置支持。 通过启动一些相同的工作进程，您将得到一个默认不共享的并发系统，使构build正确和可扩展的实现变得容易得多。

是否有使用当前线程的ExecutorService？

我所追求的是一种兼容的方式来configuration使用线程池或不使用。 理想情况下，其他代码不应该受到影响。 我可以使用1个线程的线程池，但这不是我想要的。 有任何想法吗？ ExecutorService es = threads == 0 ? new CurrentThreadExecutor() : Executors.newThreadPoolExecutor(threads); // es.execute / es.submit / new ExecutorCompletionService(es) etc

什么是互斥量？

互斥量是一种常用于解决multithreading问题的编程概念。 我对社区的问题： 什么是互斥量，你如何使用它？

为什么我的++不是primefaces的？

为什么i++在Java中不是primefaces的？ 为了让Java更深入一些，我试着去计算线程循环执行的频率。 所以我用了一个 private static int total = 0; 在主类。 我有两个线程。 线程1：打印System.out.println("Hello from Thread 1!"); 线程2：打印System.out.println("Hello from Thread 2!"); 我计算由线程1和线程2打印的行。但线程1 +线程2的行数与打印的总行数不匹配。 这是我的代码： import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.logging.Level; import java.util.logging.Logger; public class Test { private static int total = 0; private static int countT1 = 0; private static int countT2 = 0; private boolean run […]

你什么时候调用java的thread.run（）而不是thread.start（）？

…这个问题说的就是我相信的一切！

这个golang代码有什么问题？

虽然SayHello()按预期执行，但goroutine不打印任何内容。 package main import "fmt" func SayHello() { for i := 0; i < 10 ; i++ { fmt.Print(i, " ") } } func main() { SayHello() go SayHello() }

Java等待并通知：IllegalMonitorStateException

我不完全了解wait和notify （ Object ）的工作，结果我不得不削减我的尝试到下面的代码段。 Main.java： import java.util.ArrayList; class Main { public static Main main = null; public static int numRunners = 4; public static ArrayList<Runner> runners = null; public static void main(String[] args) { main = new Main(); } Main() { runners = new ArrayList<Runner>(numRunners); for (int i = 0; i < numRunners; i++) { […]

如何使用SwingWorker模拟缓冲的外围设备？

我将这个练习作为一个教学工具来帮助我刻录一些Java GUI编程概念。 我在寻找的是一个普遍的理解，而不是一个具体问题的详细解决scheme。 我期望编写这个“正确的”将教会我很多关于如何处理未来的multithreading问题。 如果这个论坛太笼统，可能属于程序员？ 我正在模拟一个读卡器。 它有一个graphics用户界面（GUI），允许我们将卡片加载到漏斗中，然后按下开始（Start）等，但其主要的“客户端”是CPU，运行在单独的线程和请求卡上。 读卡器维护一个缓冲区。 如果卡片请求进来，而且缓冲区是空的，读卡器必须从漏斗读取一张卡片（这需要1/4秒钟，这是1962年）。 卡被读入缓冲区后，读卡器将缓冲区发送给CPU，并在下一个请求之前立即启动另一个缓冲区加载操作。 如果不仅缓冲器是空的，而且料斗中没有卡片，那么我们必须等到操作员在料斗中放置了一个平台并按下开始（总是启动缓冲器加载操作）。 在我的实现中，卡片请求以invokeLater()方式发送到读卡器，在EDT上排队运行。 在myRunnable.run()时间，一个缓冲区将是可用的（在这种情况下，我们可以把它发送到CPU，并启动另一个缓冲区加载操作），或缓冲区将是空的。 如果它是空的呢？ 两种可能性：（a）飞行中已经有一个缓冲载入操​​作，或者（b）卡片仓是空的（或尚未启动）。 无论哪种情况，保持美国东部时间都是不可接受的。 工作（和等待）必须在后台线程上完成。 为了简单起见，我试图产生一个SwingWorker来响应每个卡请求，而不pipe缓冲区的状态如何。 伪代码是： SwingWorker worker = new SwingWorker<Void, Void>() { public Void doInBackground() throws Exception { if (buffer.isEmpty()) { /* * fill() takes 1/4 second (simulated by Thread.sleep) * or possibly minutes if we need to have another * […]

如何使ThreadPoolExecutor的submit（）方法块如果饱和？

我想创build一个ThreadPoolExecutor ，以便当它达到其最大值并且队列已满时， sumbit()方法会在尝试添加新任务时阻塞。 我是否需要实现一个自定义的RejectedExecutionHandler ，或者是否有一个现有的方法来使用标准的Java库做到这一点？