如何解决创建具有唯一 id 的多个线程线程不重叠
更新
我正在解决一个生产者/消费者问题,我想创建几个生产者和消费者(几个线程),我有一个问题,如何正确创建多个线程,以便一个任务不会由两个线程执行(每个线程执行不同的任务)。
代码:我试着像这里这样循环:
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
public class ProducerConsumerExample {
public static void main(String[] args) {
BlockingQueue<String> blockingQueue = new ArrayBlockingQueue<>(10);
for (int i = 0; i < 10 ; i++) {
Producer producer = new Producer(blockingQueue);
Consumer consumer = new Consumer(blockingQueue);
Thread producerThread = new Thread(producer);
Thread consumerThread = new Thread(consumer);
producerThread.start();
consumerThread.start();
}
}
}
输出:但它不起作用,因为线程相互重叠
Producer produced : 1619703940537
Producer produced : 1619703940537
Producer produced : 1619703940537
Producer produced : 1619703940537
consumed gets: 1619703940537
consumed gets: 1619703940537
consumed gets: 1619703940537
consumed gets: 1619703940537
Producer produced : 1619703940537
consumed gets: 1619703940537
解决方法
您正在寻找的是线程池。 Java 中包含了各种开箱即用的实现。这是我从 javatpoint 中得出的定义:
Java 线程池代表一组等待作业并多次重用的工作线程。在线程池的情况下,创建一组固定大小的线程。服务提供者从线程池中拉出一个线程并为其分配作业。
您可以查看以下页面了解更多信息:
https://www.baeldung.com/thread-pool-java-and-guava https://docs.oracle.com/javase/tutorial/essential/concurrency/pools.html
,您看到多个线程使用相同的 System.currentTimeMillis()
值,这使得无法判断发生了什么。将您传递到队列中的令牌更改为唯一的 PER Producer 并包含线程名称:
public void run() {
int counter=0;
while (true) {
try {
String token = Thread.currentThread().toString() + "#"+(counter++);
this.blockingQueue.put(token );
System.out.println("Producer produced nr: " + token );
} catch (InterruptedException e ) {
System.out.println("Producer was interrupted");
}
sleep();
}
}
更改 Consumer.run()
以打印线程名称,您将更清楚地看到哪个 Consumer 实例正在消费每个操作以及哪个 Producer:
System.out.println("consumer "+Thread.currentThread()+" gets: " + element);
这有望证明这些是几个生产者 + 消费者处理程序以及生产者-消费者从同一个 BlockingQueue 发送和接收项目的不同排列。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。