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

小咪咪 2022-11-12 10:57 160阅读 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 条评论，160人围观）

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

相关阅读

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

相关并发、并行和线程、进程

并发、并行和线程、进程进程线程进程线程二者对比并行例子进程程序由指令和数据组成，但这些指令要运行，数据要读写，就

逃离我推掉我的手/ 2022年12月24日 05:57/ 0 赞/ 155 阅读

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

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

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

相关 java获取线程池中指定线程数_在java项目中使用线程池如何实现获取运行线程数并控制线程启动速度...

在java项目中使用线程池如何实现获取运行线程数并控制线程启动速度发布时间：2020-11-20 16:34:44 来源：亿速云阅读：97 作者：Leah 这期内

浅浅的花香味﹌/ 2022年11月07日 14:54/ 0 赞/ 3 阅读

相关 Java线程简介（什么是线程）

一、线程概述线程是程序运行的基本执行单元。当操作系统(不包括单线程的操作系统，如微软早期的DOS)在执行一个程序时，会在系统中建立一个进程，而在这个进程中，必须至少建立一个

小鱼儿/ 2022年05月09日 07:46/ 0 赞/ 264 阅读

相关 Java 线程通信线程组线程异常处理机制

线程通信传统的线程通信方法概述： wait方法：导致当前线程等待，直到其他线程调用该同步监视器的notify()方法或notifyAll()方法来唤醒该

柔情只为你懂/ 2022年02月23日 12:16/ 0 赞/ 297 阅读