java implement Higher-order function ,support map,filter , reduce with parallel, android
Java
Latest commit ab9a770 Jan 4, 2017 tangxiaolv update README
Permalink
Failed to load latest commit information.
gradle/wrapper
img
src
.gitignore
LICENSE
README.md update README Jan 4, 2017
README_CN.md
build.gradle
gradlew
gradlew.bat init Dec 25, 2016
settings.gradle release 1.0.1 Dec 28, 2016

README.md

HFunc

Download

English | 中文

A fast and simple Java Higher-order function lib. Support serial compute and parallel compute. Applies to Java and Android.

Support

  • map
  • filter
  • reduce

Gradle

dependencies {
    compile 'com.library.tangxiaolv:hfunc:1.0.1'
}

Guide

Example:
//data collection
List<Integer> c = new ArrayList<>();
for (int i = 1; i < 101; i++) {
    c.add(i);
}

map:

serial compute: 1078ms
List<String> result = HFunc.map(c, new HFunc.Func1<Integer, String>() {
    @Override
    public String call(Integer item) {
        try {
            Thread.sleep(10);
        } catch (InterruptedException e) {}
        return Integer.toString(item * 2);
    }
});

parallel compute: 150ms
List<String> result = HFunc.mapParallel(c, new HFunc.Func1<Integer, String>() {
    @Override
    public String call(Integer item) {
        try {
            Thread.sleep(10);
        } catch (InterruptedException e) {}
        return Integer.toString(item * 2);
    }
});

filter:

serial compute: 1037ms
List<Integer> result = HFunc.filter(c, new HFunc.Func1<Integer, Boolean>() {
    @Override
    public Boolean call(Integer item) {
        try {
            Thread.sleep(10);
        } catch (InterruptedException e) {}
        return item % 2 != 0;
    }
});

parallel compute: 159ms
List<Integer> result = HFunc.filterParallel(c, new HFunc.Func1<Integer, Boolean>() {
    @Override
    public Boolean call(Integer item) {
        try {
            Thread.sleep(10);
        } catch (InterruptedException e) {}
        return item % 2 != 0;
    }
});

reduce:

serial compute: 1061ms
Integer result = HFunc.reduce(c, new HFunc.Func2<Integer, Integer, Integer>() {
    @Override
    public Integer call(Integer merge, Integer next) {
        try {
            Thread.sleep(10);
        } catch (InterruptedException e) {}
        return merge + next;
    }
});

parallel compute: 239ms
Integer result = HFunc.reduceParallel(c, new HFunc.Func2<Integer, Integer, Integer>() {
    @Override
    public Integer call(Integer merge, Integer next) {
        try {
            Thread.sleep(10);
        } catch (InterruptedException e) {}
        return merge + next;
    }
});

LICENSE

Copyright 2016 XiaoLv Tang

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

    http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.