java 线程是并行,在java中使用线程进行并行处理

小咪咪 2022-11-12 10:57 230阅读 0赞

如上所述,您可以使用阻塞队列与生产者使用者

要么

您可以使用java并发的倒计时锁存来解决您的问题.

CountDownLatch如何工作？

CountDownLatch.java类定义了一个构造函数：

//构造一个用给定计数初始化的CountDownLatch.

public void CountDownLatch(int count) \{...\}

这个计数本质上就是锁存器应该等待的线程数.此值只能设置一次,而CountDownLatch不提供其他机制来重置此计数.

与CountDownLatch的第一次交互是主线程,它是等待其他线程的goind.这个主线程必须在启动其他线程后立即调用CountDownLatch.await()方法.执行将在await()方法上停止,直到其他线程完成执行.

其他N个线程必须引用latch对象,因为它们需要通知CountDownLatch对象它们已经完成了它们的任务.此通知通过以下方法完成：CountDownLatch.countDown();每次调用方法都会减少构造函数中设置的初始计数,因此,当所有N个线程都调用此方法时,count会达到零,并允许主线程通过await()方法恢复执行.

下面是一个简单的例子.在Decrementer之后调用了countDown()3次

CountDownLatch,the waiting Waiter is released from the await() call.

CountDownLatch latch = new CountDownLatch(3);

Waiter waiter = new Waiter(latch);

Decrementer decrementer = new Decrementer(latch);

new Thread(waiter) .start();

new Thread(decrementer).start();

Thread.sleep(4000);

public class Waiter implements Runnable\{

CountDownLatch latch = null;

public Waiter(CountDownLatch latch) \{

this.latch = latch;

\}

public void run() \{

try \{

latch.await();

\} catch (InterruptedException e) \{

e.printStackTrace();

\}

System.out.println("Waiter Released");

\}

\}

public class Decrementer implements Runnable \{

CountDownLatch latch = null;

public Decrementer(CountDownLatch latch) \{

this.latch = latch;

\}

public void run() \{

try \{

Thread.sleep(1000);

this.latch.countDown();

Thread.sleep(1000);

this.latch.countDown();

Thread.sleep(1000);

this.latch.countDown();

\} catch (InterruptedException e) \{

e.printStackTrace();

\}

\}

\}

在您的情况下,您可以使用callable来创建线程而不是runnable,因为您需要从一个线程获取retrun值并且必须将该值传递给第二个线程.

发表评论取消回复

表情：

评论列表（有 0 条评论，230人围观）

还没有评论，来说两句吧...

相关阅读

相关如何在Java中实现多线程并行计算

在Java中，你可以使用`Thread`和`ExecutorService`等工具来实现多线程并行计算。以下是一个基本的例子，展示了如何创建一个线程来执行一个任务，并使用`

太过爱你忘了你带给我的痛/ 2025年03月19日 03:45/ 0 赞/ 33 阅读

相关如何在Java中使用多线程并行处理

在Java中，你可以通过以下步骤来创建多线程并行处理： 1. **创建类**：首先，你需要创建一个Java类。这个类将作为多线程的主体。 ```java public cl

左手的ㄟ右手/ 2024年10月23日 17:00/ 0 赞/ 111 阅读

相关在Java中，如何使用线程池进行异步任务处理？

在Java中，我们可以使用ExecutorService和Runnable来创建和管理线程池进行异步任务处理。以下是一个简单的示例： ```java import java.

迈不过友情╰/ 2024年09月27日 11:39/ 0 赞/ 128 阅读

相关如何在Java中实现线程池并进行优化

在Java中，我们可以使用`ExecutorService`和`ThreadPoolExecutor`来创建和管理线程池。以下是一个基本的示例，以及一些优化策略： 1. **

ゝ一纸荒年。/ 2024年09月23日 03:21/ 0 赞/ 132 阅读

相关 java线程池：如何在 Java 线程池中提交线程？

![在这里插入图片描述][1b70ec2e4dc0432a86261758c4e4d53a.png] [1b70ec2e4dc0432a86261758c4e4d53a.p

朱雀/ 2024年02月20日 12:30/ 0 赞/ 253 阅读

相关使用线程、线程池和任务在 C# 中进行并行处理

多线程是在您的进程中同时运行多个操作以最大可能地利用 CPU 功率的概念。一个线程定义了一个执行路径。当进程启动时，它会启动一个称为主线程的线程。如果您的程序有许多复杂的路径，

- 日理万妓/ 2023年10月01日 20:14/ 0 赞/ 88 阅读

相关 Java--多线程之并发，并行，进程，线程（一）

[Java--多线程之并发，并行，进程，线程（一）\_MinggeQingchun的博客-CSDN博客][Java--_MinggeQingchun_-CSDN] [Java

港控/mmm°/ 2023年10月01日 09:33/ 0 赞/ 94 阅读

相关 android 线程之创建一个子线程，并在UI线程中进行交互

package littest.ghq.com.test; import android.support.v7.app.AppCompatActivi

ゝ一纸荒年。/ 2023年06月18日 08:59/ 0 赞/ 236 阅读

相关 java 线程池中线程异常处理

背景介绍提交到线程池的线程如果不自己管理异常，当线程发生异常以后，这个线程会进入到wating状态。导致线程不可用解决方案自己捕获异常，注意catch

女爷i/ 2022年12月28日 11:22/ 0 赞/ 241 阅读

相关 java 线程是并行,在java中使用线程进行并行处理

如上所述,您可以使用阻塞队列与生产者使用者要么您可以使用java并发的倒计时锁存来解决您的问题. CountDownLatch如何工作？ CountDownLatc

小咪咪/ 2022年11月12日 10:57/ 0 赞/ 231 阅读