文档章节

Java并发编程高级篇(四):运行多个任务并处理第一个结果

阿拉德大陆的魔法师
 阿拉德大陆的魔法师
发布于 2017/03/02 09:34
字数 1195
阅读 36
收藏 0

接下来,我们来模拟一个用户验证过程,提供两种验证机制,任何一种验证机制验证成功即可通过验证,而不用等两种验证机制都验证成功。

创建UserValidator类,它通过休眠一个随机时间来模拟用户验证过程。

import java.util.Random;
import java.util.concurrent.TimeUnit;

/**
 * Created by hadoop on 2016/11/2.
 */
public class UserValidator {
    private String name;

    public UserValidator(String name) {
        this.name = name;
    }

    public boolean validate(String username, String password) {
        long duration = (long) (Math.random() * 10);

        System.out.printf("Validator %s: validating a user during %d seconds\n", name, duration);

        try {
            TimeUnit.SECONDS.sleep(duration);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        return new Random().nextBoolean();
    }

    public String getName() {
        return name;
    }
}

接下来我们创建一个Callable类,用于调用验证模块来实现用户验证,验证成功后,返回当前验证方式名称,验证失败则抛出异常。

import java.util.concurrent.Callable;

/**
 * Created by hadoop on 2016/11/2.
 */
public class TaskValidator implements Callable<String> {
    private UserValidator validator;

    private String username;
    private String password;

    public TaskValidator(UserValidator validator, String user, String password) {
        this.validator = validator;
        this.username = user;
        this.password = password;
    }

    @Override
    public String call() throws Exception {
        if (!validator.validate(username, password)) {
            System.out.printf("%s: The username has not been found\n", validator.getName());
            throw new Exception("Error validating user");
        }

        System.out.printf("%s: The username has been found\n", validator.getName());

        return validator.getName();
    }
}

最后创建主线程类。在主线程类中初始化两个验证器,然后启动两个验证线程来进行用户验证。调用invokeAny()方法,这个方法接收一个List<Callable>作为参数,当有任何一个线程执行完毕后,直接返回这个线程的返回值。

  • 第一个完成的验证器验证成功,则返回第一个完成的验证器的名称。
  • 第一个完成的验证器验证失败,第二个完成的验证器验证成功,再返回第二个完成的验证器名称。
  • 两个验证器都验证失败,那么invokeAny()返回ExecutionException。
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * 4.5 运行多个任务并处理第一个结果
 *
 * 并发编程中常见一个的一个问题是,当采用并发任务来解决一个问题的时候,往往只考虑第一个返回的结果。
 * 比如使用多个线程采用不同的排序算法对数组进行排序,我们只关心第一个排序完成的线程,它是最快的算法。
 *
 * 在本节我们使用ThreadPoolExecutor类来实现这个场景。
 * 模拟使用两种方式对用户进行验证,但是只要有一种机制验证成功,那么就算验证通过。
 *
 * 这个范例的关键点在Main主类中:我们调用了ExecutorService的invokeAny()方法。
 * 这个方法接收一个任务列表,然后运行任务,并且返回第一个完成并且没有抛出异常的任务执行结果。
 * 这个方法的返回类型与任务重call()方法的返回类型相同。在这里返回String类型。
 *
 * 范例中定义了两个UserValidator对象,他们返回随机的boolean值。
 * 两个UserValidator对象分别被两个TaskValidator任务调用,用来验证用户。
 * 如果UserValidator对象的validate方法返回false那么抛出异常,那么TaskValidator抛出异常,否则返回当前UserValidator名字。
 *
 * 1. 如果两个UserValidator都验证通过,那么invokeAny()返回第一个完成的TaskValidator的执行结果。
 * 2. 如果第一个任务验证通过,第二个任务抛出异常,那么invokeAny()返回第一个完成的TaskValidator的执行结果。
 * 3. 如果第一个任务抛出异常,第二个任务验证通过,那么invokeAny()返回第二个完成的TaskValidator的执行结果。
 * 4. 如果两个任务都抛出异常,那么invokeAny()将抛出ExecutionException异常。
 *
 * Created by hadoop on 2016/11/2.
 */
public class Main {
    public static void main(String[] args) {
        UserValidator validator1 = new UserValidator("LDAP");
        UserValidator validator2 = new UserValidator("DB");

        String username = "test";
        String password = "test";

        TaskValidator task1 = new TaskValidator(validator1, username, password);
        TaskValidator task2 = new TaskValidator(validator2, username, password);

        List<TaskValidator> tasks = new ArrayList<TaskValidator>();
        tasks.add(task1);
        tasks.add(task2);

        ExecutorService exerutor = Executors.newCachedThreadPool();
        try {
            String result = exerutor.invokeAny(tasks);

            System.out.printf("Main: Result: %s\n", result);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }

        exerutor.shutdown();
        System.out.printf("Main: Eno of the execution\n");
    }
}

有一个验证成功。

Validator LDAP: validating a user during 7 seconds
Validator DB: validating a user during 7 seconds
DB: The username has been found
LDAP: The username has not been found
Main: Result: DB
Main: Eno of the execution

Process finished with exit code 0

都验证失败的结果。

Validator DB: validating a user during 7 seconds
Validator LDAP: validating a user during 3 seconds
LDAP: The username has not been found
DB: The username has not been found
Main: Eno of the execution
java.util.concurrent.ExecutionException: java.lang.Exception: Error validating user
	at java.util.concurrent.FutureTask.report(FutureTask.java:122)
	at java.util.concurrent.FutureTask.get(FutureTask.java:188)
	at java.util.concurrent.AbstractExecutorService.doInvokeAny(AbstractExecutorService.java:193)
	at java.util.concurrent.AbstractExecutorService.invokeAny(AbstractExecutorService.java:215)
	at cookbook.chapter_04.section_05.Main.main(Main.java:50)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at com.intellij.rt.execution.application.AppMain.main(AppMain.java:147)
Caused by: java.lang.Exception: Error validating user
	at cookbook.chapter_04.section_05.TaskValidator.call(TaskValidator.java:24)
	at cookbook.chapter_04.section_05.TaskValidator.call(TaskValidator.java:8)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)

© 著作权归作者所有

阿拉德大陆的魔法师
粉丝 27
博文 91
码字总数 83019
作品 0
西城
程序员
私信 提问
读书笔记之《Java并发编程的艺术》-线程池和Executor的子孙们

读书笔记部分内容来源书出版书,版权归本书作者,如有错误,请指正。 欢迎star、fork,读书笔记系列会同步更新 git https://github.com/xuminwlt/j360-jdk module j360-jdk-thread/me.j360....

Hi徐敏
2015/11/11
733
1
Java 编程之美:并发编程基础晋级篇

本文来自作者 加多 在 GitChat 上分享 「Java 并发编程之美:并发编程基础晋级篇」 编辑 | Mc Jin 借用 Java 并发编程实践中的话,编写正确的程序并不容易,而编写正常的并发程序就更难了! ...

gitchat
2018/04/18
0
0
ForkJoinPool 探索

介绍 “分而治之“是理清思路和解决问题的一个重要的方法。大到系统架构对功能模块的拆分,小到归并排序的实现,无一不在散发着分而治之的思想。在实现分而治之的算法的时候,我们通常使用递...

robinhan
01/10
0
0
Java 并发:Executors 和线程池

本文译自:Java Concurrency – Part 7 : Executors and thread pools 让我们开始来从入门了解一下 Java 的并发编程。 本文主要介绍如何开始创建线程以及管理线程池,在 Java 语言中,一个最...

红薯
2010/09/15
34.2K
18
读书笔记之《Java并发编程的艺术》-并发编程容器和框架(重要)

读书笔记部分内容来源书出版书,版权归本书作者,如有错误,请指正。 欢迎star、fork,读书笔记系列会同步更新 git https://github.com/xuminwlt/j360-jdk module j360-jdk-thread/me.j360....

Hi徐敏
2015/11/11
685
1

没有更多内容

加载失败,请刷新页面

加载更多

Experts say the weaker pound is drawing investors to the UK tech sector

UK tech companies secured a record £5.5bn in foreign investment in the first seven months of this year, research shows. This was more than the amount invested per capita in th......

wowloop
27分钟前
5
0
Add support for Android 9-patch images in BorderImage

The 9-patch image implementation in Qt Quick Controls 1 is an internal implementation detail of the Android style. It cannot handle .9.png image files out of the box, but takes ......

shzwork
31分钟前
4
0
c/c++日期时间处理函数小结

日期时间处理函数: 日期时间转为字符串 strftime/std::put_time 字符串解析成日期时间 strptime/std::get_time 时间结构转换:time_t->tm localtime:time_t->tm 时间结构转换:tm->time_t ...

chuqq
36分钟前
5
0
Apache Flink 进阶入门(二):Time 深度解析

前言 Flink 的 API 大体上可以划分为三个层次:处于最底层的 ProcessFunction、中间一层的 DataStream API 和最上层的 SQL/Table API,这三层中的每一层都非常依赖于时间属性。时间属性是流处...

大涛学长
37分钟前
4
0
创龙基于Xilinx Artix-7系列FPGA处理器

SOM-TLA7是一款由广州创龙基于Xilinx Artix-7系列FPGA自主研发的核心板,可配套广州创龙Artix-7开发板使用。核心板尺寸仅70mm*50mm,采用沉金无铅工艺的10层板设计,专业的PCB Layout保证信号...

Tronlong创龙
43分钟前
5
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部