java之forkjoin体验

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53

package org.mango.forkjoin;

import cn.hutool.http.HttpUtil;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.concurrent.RecursiveTask;

public class ServiceTask extends RecursiveTask<String> {
    private String url;
    public ServiceTask(String url){
        this.url = url;
    }

    @Override
    protected String compute() {
        String result = HttpUtil.get(this.url);
        System.out.println(Thread.currentThread().getName()+"==>"+new Date().toLocaleString()+":"+result.substring(0,100));
        return result;
    }
    /**
     * 提交任务执行后返回结果
     * @return
     */
    public static List<String> execute(List<String> urls){
        List<String> resultList = new ArrayList<>();
        List<ServiceTask> subTasks = new ArrayList<ServiceTask>();
        for(String url : urls){
            ServiceTask subTask = new ServiceTask(url);
            subTasks.add(subTask);
            subTask.fork();
        }
        for(ServiceTask t : subTasks){
            resultList.add(t.join());
        }
        return resultList;
    }

    public static void main(String[] args) {
        List<String> urls = new ArrayList<>();
        for(int i=0;i<100;i++) {
            urls.add("http://mg.meiflower.top/card/rand");
        }
        long start = System.currentTimeMillis();
        List<String> resultList = ServiceTask.execute(urls);
        long end = System.currentTimeMillis();
        System.out.println("耗时"+(end-start)+"ms");
        /*for(String result : resultList){
            System.out.println(result.substring(0,100));
        }*/
    }
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11

ForkJoinPool.commonPool-worker-3==>2020-3-6 10:56:30:{"state":1,"msg":"","row":{"id":11,"v_key":"FastDFS","v_value":"FastDFS是一个开源的轻量级分布式文件系统，它对文件进行管理，功能包
ForkJoinPool.commonPool-worker-6==>2020-3-6 10:56:30:{"state":1,"msg":"","row":{"id":2,"v_key":"Vagrant","v_value":"Vagrant是一个基于Ruby的工具，用于创建和部署虚拟化开发环境。它 
ForkJoinPool.commonPool-worker-5==>2020-3-6 10:56:30:{"state":1,"msg":"","row":{"id":10,"v_key":"杨绛先生","v_value":"杨绛（1911年7月17日—2016年5月25日），本名杨季康， [1]  江
ForkJoinPool.commonPool-worker-1==>2020-3-6 10:56:30:{"state":1,"msg":"","row":{"id":10,"v_key":"杨绛先生","v_value":"杨绛（1911年7月17日—2016年5月25日），本名杨季康， [1]  江
ForkJoinPool.commonPool-worker-4==>2020-3-6 10:56:30:{"state":1,"msg":"","row":{"id":10,"v_key":"杨绛先生","v_value":"杨绛（1911年7月17日—2016年5月25日），本名杨季康， [1]  江
ForkJoinPool.commonPool-worker-7==>2020-3-6 10:56:30:{"state":1,"msg":"","row":{"id":4,"v_key":"辛辣","v_value":"辛辣是一个汉语词汇，读音为xīn là，是一种味道。意思是尖锐而强烈，此类食物包括葱
ForkJoinPool.commonPool-worker-2==>2020-3-6 10:56:30:{"state":1,"msg":"","row":{"id":10,"v_key":"杨绛先生","v_value":"杨绛（1911年7月17日—2016年5月25日），本名杨季康， [1]  江
ForkJoinPool.commonPool-worker-3==>2020-3-6 10:56:30:{"state":1,"msg":"","row":{"id":4,"v_key":"辛辣","v_value":"辛辣是一个汉语词汇，读音为xīn là，是一种味道。意思是尖锐而强烈，此类食物包括葱
ForkJoinPool.commonPool-worker-5==>2020-3-6 10:56:30:{"state":1,"msg":"","row":{"id":2,"v_key":"Vagrant","v_value":"Vagrant是一个基于Ruby的工具，用于创建和部署虚拟化开发环境。它 
ForkJoinPool.commonPool-worker-6==>2020-3-6 10:56:30:{"state":1,"msg":"","row":{"id":5,"v_key":"食品不耐受性","v_value":"食品不耐受性是对食物的一种不良反应，其不涉及免疫系统。反应的引起是由于不消化
耗时613ms