`
dsxwjhf
  • 浏览: 73141 次
  • 性别: Icon_minigender_1
  • 来自: 安徽
社区版块
存档分类
最新评论

Fork/Join 入门

阅读更多
以下示例来自网络。

package com.wjxie.test.forkjoin;

import java.util.concurrent.ExecutionException;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.Future;
import java.util.concurrent.RecursiveTask;

/**
 * 并行计算 1 到 n 之和。
 * 
 * Created by wenjing.xie on 2016年4月20日
 */
public class Calculator extends RecursiveTask<Integer> {

    private static final long serialVersionUID = 1L;

    private static final int THRESHOLD = 100;
    private int start;
    private int end;

    public Calculator(int start, int end) {
        this.start = start;
        this.end = end;
    }

    @Override
    protected Integer compute() {
        int sum = 0;
        if (end - start < THRESHOLD) {
            for (int i = start; i < end; i++) {
                sum += i;
            }
        } else {
            int middle = (start + end) / 2;
            Calculator left = new Calculator(start, middle);
            Calculator right = new Calculator(middle + 1, end);
            left.fork();
            right.fork();
            sum = left.join() + right.join();
        }
        return sum;
    }

    public static void main(String[] args) throws InterruptedException, ExecutionException {
        ForkJoinPool forkJoinPool = new ForkJoinPool();
        // 继承关系: RecursiveTask --> ForkJoinTask --> Future
        Future<Integer> result = forkJoinPool.submit(new Calculator(0, 10000));
        System.out.println("当前活跃线程数: " + Thread.getAllStackTraces().size());
        System.out.println(result.get());
    }

}


package com.wjxie.test.forkjoin;

import java.util.Arrays;
import java.util.Random;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.RecursiveAction;
import java.util.concurrent.TimeUnit;

/**
 * 并行排序数组。
 * 
 * Created by wenjing.xie on 2016年4月20日
 */
public class SortTask extends RecursiveAction {

    private static final long serialVersionUID = 1L;

    final long[] array;
    final int start;
    final int end;
    private int THRESHOLD = 100;

    public SortTask(long[] array) {
        this.array = array;
        this.start = 0;
        this.end = array.length - 1;
    }

    public SortTask(long[] array, int start, int end) {
        this.array = array;
        this.start = start;
        this.end = end;
    }

    protected void compute() {
        if (end - start < THRESHOLD)
            sequentiallySort(array, start, end);
        else {
            int pivot = partition(array, start, end);
            new SortTask(array, start, pivot - 1).fork();
            new SortTask(array, pivot + 1, end).fork();
        }
    }

    /**
     * 取数组 array[start-end] 的中间数的下标,并使得 array[pivot] 左边的元素比自己小,右边的比自己大。
     */
    private int partition(long[] array, int start, int end) {
        long x = array[end];
        int i = start - 1;
        for (int j = start; j < end; j++) {
            if (array[j] <= x) {
                i++;
                swap(array, i, j);
            }
        }
        swap(array, i + 1, end);
        return i + 1;
    }

    private void swap(long[] array, int i, int j) {
        if (i != j) {
            long temp = array[i];
            array[i] = array[j];
            array[j] = temp;
        }
    }

    private void sequentiallySort(long[] array, int lo, int hi) {
        Arrays.sort(array, lo, hi + 1);
    }

    public static void main(String[] args) throws InterruptedException {
        int SIZE = 10000;
        ForkJoinPool forkJoinPool = new ForkJoinPool();
        Random rnd = new Random();
        long[] array = new long[SIZE];
        for (int i = 0; i < SIZE; i++) {
            array[i] = rnd.nextInt();
        }
        forkJoinPool.submit(new SortTask(array));
        forkJoinPool.shutdown();
        forkJoinPool.awaitTermination(1000, TimeUnit.SECONDS);
        for (long item : array) {
            System.out.println(item);
        }
    }

}

分享到:
评论

相关推荐

    ForkJoin并发框架入门示例

    `ForkJoin入门.ppt`是PPT文件,里面详细介绍了并发与并行的概念以及ForkJoin框架的使用方法,包括如何创建和执行ForkJoin任务。`FileSize.java`可能包含了一个实际的ForkJoinTask示例,用于计算文件大小或其他类似的...

    java并发编程从入门到精通

    《Java并发编程从入门到精通》内容包括并发编程概念,线程,线程安全,线程集合类,线程阀,线程池,Fork/Join,线程、线程池在互联网项目开发的应用,线程监控及线程分析,Android中线程应用。 本书适合Java开发...

    风辰的CUDA入门教程

    - **CUDA与Fork/Join**:在CUDA中,可以通过类似Fork/Join的方式来实现数据并行处理,但具体实现方式有所不同,更多依赖于CUDA的线程模型和内存模型。 **知识点2:CUDA线程模型** - **线程组织**:CUDA中的线程按照...

    CUDA入门教程 GPU并行计算

    ### CUDA入门教程:GPU并行计算的关键知识点 #### 第一章、CUDA的基本内容 ##### 第一节、CUDA及GPU简介 - **GPU简介**:GPU(Graphic Processing Unit)最初主要负责图形渲染工作,但随着时间的发展,GPU凭借其...

    Java 8编程入门学习文档.zip

    Java 8对Fork/Join框架和并发集合进行了优化,如Parallel Streams的引入,使得并行处理更加高效。另外,新引入的CompletableFuture类支持异步编程和链式操作。 9. **新的枚举方法**: EnumSet和EnumMap类得到了...

    Java8零基础入门视频教程

    Fork/Join框架是基于分治策略的并行计算模型,可以将大任务拆分成小任务并行执行,提高计算效率。Parallel Streams是Java8中的并行流,可以自动利用多核处理器的优势,对集合进行并行操作,显著提升性能。 除此之外...

    Java语言程序设计教程(Java 7) 入门与提高篇PPT

    7. **多线程**:Java 7在多线程方面进行了优化,提供了更强大的并发工具,如Fork/Join框架和CountDownLatch等,使并发编程更加高效和易管理。 8. **反射和注解**:反射允许程序在运行时检查类、接口、字段和方法的...

    java入门笔记.pdf

    文档中也提及了Java 5中引入的一些并发工具类,比如Future、Callable、Fork/Join框架,以及JDK 8对并发编程的新支持。 ### Java集合框架 集合框架是Java API的一部分,提供了丰富的接口和实现类,例如List、Set、...

    CS62sophomoricParallelismAndConcurrency

    本文档是关于Java中并行化与并发性的入门教材,主要面向大学二年级的学生。教材主要介绍共享内存并行化和并发性的基本概念,并且讨论了与Java相关的特定技术,例如线程和共享内存的使用。教材内容详细,从并行化和...

    SystemC_2_1_features.pdf

    动态进程创建和同步的语言构造包括sc_spawn(), sc_spawn_options(), SC_FORK, SC_JOIN, sc_process_handle::wait(), sc_bind(), sc_ref() 和 sc_cref()。下面将对这些构造进行详细介绍。 基本使用sc_spawn的方式...

    Beginning Java 7

    ### Java 7 入门详解 #### 一、Java 7 概览 Java 7 是 Java 编程语言的一个重要版本,它引入了一系列新特性与改进,旨在提高开发效率和程序性能。本书《Beginning Java 7》为读者提供了一个全面的学习路径,不仅...

    Hive编程指南+HIVE从入门到精通+Hive高级编程+Apache Oozie

    3. **控制结构**: 使用决策、fork/join和重试等控制流来构建复杂的逻辑流程。 4. **调度与触发**: 设置定时器或依赖于其他作业的完成来触发工作流。 5. **监控与管理**: 监控工作流状态,管理和回滚失败的任务。 ...

    jdk类库帮助手册1.8_China.rar

    在并发编程方面,Fork/Join框架是另一个值得关注的特性。它允许将大任务分解为小任务并行执行,从而提高计算效率。配合Parallel Streams,可以轻松实现高效的并行计算。 最后,JDK 1.8还对反射和注解处理进行了优化...

    jdk6-x64.zip

    - 引入了新的并发工具类,如ConcurrentHashMap和Fork/Join框架,帮助开发者编写更高效的多线程代码。 除此之外,JDK1.6还对垃圾收集机制进行了优化,提高了内存管理效率,并引入了新的诊断工具和JMX(Java ...

    SpringBoot-:来自https的fork

    为所有Spring开发提供根本上更快且可广泛访问的入门经验 开箱即用,但是随着需求开始偏离默认值,您会很快摆脱困境 提供一系列大型项目共有的非功能性功能(例如,嵌入式服务器,安全性,指标,运行状况检查,外部...

    Verilog入门手册

    接下来是结构化语句,包括顺序语句(如assign、always、initial等)和并发语句(如fork-join、begin-end等)。assign用于定义连续赋值,always块用于描述时序逻辑,initial块则常用于初始化程序。并发语句则允许多个...

    Perl语言入门(第五版-中文版).pdf

    用fork开展地下工作 发送及接收信号 习题 第十七章高级perl技巧 用eval捕获错误 用grep来筛选列表 用map对列表进行转换 不带引号的哈希键 切片 习题 附录a习题解答 附录b超越小骆驼...

    VERILOG快速入门_verilog;快速入门;_

    在实际设计中,你还会遇到各种各样的仿真概念,例如initial块用于初始化变量,fork-join结构用于并发执行任务,以及任务和函数的定义,它们可以封装重复的代码段。此外,还有非阻塞赋值()和阻塞赋值(=)的区别,...

    写给大忙人的JavaSE 8 中文版 + 英文版

    8. **并发改进**:Fork/Join框架和Parallel Streams的引入,让多线程并行计算变得更加简单,提升了Java的并行处理性能。 9. **接口的私有方法和静态方法**:JavaSE 8允许接口定义私有方法和静态方法,增强了接口的...

Global site tag (gtag.js) - Google Analytics