ゆっちのBlog

Java

CompletableFuture を解らないまま試してみた

Java

Java8 の目玉機能は並行処理を容易にするために採用された Lambda に注目が集まってます。

その他にも便利な機能が追加されているのですが何故か人気の無い？ CompletableFuture を試してみました。

これも外国語のサイトからの情報を元に解らないままゴニョゴニョしてみました。

ちなみに CompletableFuture の情報はグーグル先生に聞いてみても新しい情報は数件しかヒットしませんでした。

誰かが日本語で優しく解説してくれるのを待っていたのですが Lambda の人気の高さからか見向きもされない可愛そうな子となってます。（ヲヒ

CompletableFuture っていったい何者なの？

これまでは非同期処理の返り値を取るためには ExecutorService、 Callable、Future インターフェースを使っていました。

この CompletableFuture を使えばそれらを簡単にできちゃうよって優れもののようです。

それでは試してみましょう。

だいたいの流れをサクッと説明すると、

それぞれ、countHoge() , countFuga() , countChome() と言うメソッドで時間のかかる計算結果を取得するものとします。

それぞれ 1 秒、3 秒、7 秒と計算時間を要します。

返り値は、1 、3 、7 とします。

もちろん ExecutorService を利用します。

それぞれ CompletableFuture.supplyAsync() にて CompletableFuture を生成します。

CompletableFuture.allOf() メソッドにてそれぞれをひとまとめにします。

thenRun() メソッドにて処理を開始し、計算結果を返します。

あとは get() メソッドにて計算結果を取得すればいいだけです。

返り値を利用して新たに CompletableFuture<T> を作ることも可能です。

この CompletableFuture クラスには 50 種類ほどのメソッドが用意されてるのでかなり自由度が高くいろんなことができそうです。

ちなみに良く解らないのに適当に創ったコードなので間違いがあると思いますが笑って許してくださいませ。

package jp.yucchi.trycompletablefuture;

public class SomeWorks {
    public int countHoge()
	{
		try {Thread.sleep(1_000);}catch(InterruptedException e){throw new RuntimeException(e);}
		return 1;
	}

	public int countFuga()
	{
		try {Thread.sleep(3_000);}catch(InterruptedException e){throw new RuntimeException(e);}
		return 3;
	}

	public int countChome()
	{
		try {Thread.sleep(7_000);}catch(InterruptedException e){throw new RuntimeException(e);}
		return 7;
	}

}

package jp.yucchi.trycompletablefuture;

public class SomeWorks {

public int countHoge()

{

try {Thread.sleep(1_000);}catch(InterruptedException e){throw new RuntimeException(e);}

return 1;

}

public int countFuga()

{

try {Thread.sleep(3_000);}catch(InterruptedException e){throw new RuntimeException(e);}

return 3;

}

public int countChome()

{

try {Thread.sleep(7_000);}catch(InterruptedException e){throw new RuntimeException(e);}

return 7;

}

package jp.yucchi.trycompletablefuture;

import java.lang.management.ManagementFactory;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import java.util.logging.Level;
import java.util.logging.Logger;

public class TryCompletableFuture {

    private static final SomeWorks works = new SomeWorks();
    private static ExecutorService executor;
    private static CompletableFuture<Integer> hoge;
    private static CompletableFuture<Integer> fuga;
    private static CompletableFuture<Integer> chome;
    private static CompletableFuture<Void> doAllWorks;

    public static void main(String[] args) {

        int procs = ManagementFactory.getOperatingSystemMXBean().getAvailableProcessors();
        if (procs < 3) {
            procs = 3;
        }

        executor = Executors.newFixedThreadPool(procs);

        hoge = CompletableFuture.supplyAsync(() -> works.countHoge(), executor);
        fuga = CompletableFuture.supplyAsync(() -> works.countFuga(), executor);
        chome = CompletableFuture.supplyAsync(() -> works.countChome(), executor);
        doAllWorks = CompletableFuture.allOf(hoge, fuga, chome);

        workCompletableFutures();

        try {
            System.out.println(hoge.get());
        } catch (ExecutionException | InterruptedException ex) {
            Logger.getLogger(TryCompletableFuture.class.getName()).log(Level.SEVERE, null, ex);
        }
        
        try {
            System.out.println(fuga.get());
        } catch (InterruptedException | ExecutionException ex) {
            Logger.getLogger(TryCompletableFuture.class.getName()).log(Level.SEVERE, null, ex);
        }
        
        try {
            System.out.println(chome.get());
        } catch (InterruptedException | ExecutionException ex) {
            Logger.getLogger(TryCompletableFuture.class.getName()).log(Level.SEVERE, null, ex);
        }

        CompletableFuture<String> monad = hoge.thenApply(r -> r * r * Math.PI).thenApply(Object::toString);  
        try {
            System.out.println("monad = " + monad.get());
        } catch (InterruptedException | ExecutionException ex) {
            Logger.getLogger(TryCompletableFuture.class.getName()).log(Level.SEVERE, null, ex);
        }
        
        while (true) {
            if (doAllWorks.isDone()) {
                System.out.println("executor.shutdown()");
                executor.shutdown();
                try {
                    if (!executor.awaitTermination(20, TimeUnit.SECONDS)) {
                        System.out.println("executor.shutdownNow()");
                        executor.shutdownNow();
                        break;
                    }
                } catch (InterruptedException ex) {
                    Logger.getLogger(TryCompletableFuture.class.getName()).log(Level.SEVERE, null, ex);
                    executor.shutdownNow();
                    break;
                }
                break;
            }
        }
    }

    private static void workCompletableFutures() {

        long startTime = System.nanoTime();

        System.out.println("<---  START  --->");

        doAllWorks.thenRun(() -> {
            try {
                if ((hoge.get() + fuga.get() + chome.get()) == 11) {
                    System.out.println("<---  DONE  --->");
                } else {
                    System.out.println("<---  ERROR  --->");
                }
            } catch (ExecutionException | InterruptedException e) {
                throw new RuntimeException(e);
            }

            long time = System.nanoTime() - startTime;
            System.out.println("処理時間は、"
                    + (int) (time * 1e-9) / 3_600 + "時間"
                    + (int) ((time * 1e-9) / 60) % 60 + "分"
                    + (int) (time * 1e-9 % 60) + "秒"
                    + Double.toString((time * 1e-9 % 60) % 1).substring(2));
        });
    }
}

100

101

102

103

104

105

106

107

package jp.yucchi.trycompletablefuture;

import java.lang.management.ManagementFactory;

import java.util.concurrent.CompletableFuture;

import java.util.concurrent.ExecutionException;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.TimeUnit;

import java.util.logging.Level;

import java.util.logging.Logger;

public class TryCompletableFuture {

private static final SomeWorks works = new SomeWorks();

private static ExecutorService executor;

private static CompletableFuture<Integer> hoge;

private static CompletableFuture<Integer> fuga;

private static CompletableFuture<Integer> chome;

private static CompletableFuture<Void> doAllWorks;

public static void main(String[] args) {

int procs = ManagementFactory.getOperatingSystemMXBean().getAvailableProcessors();

if (procs < 3) {

procs = 3;

}

executor = Executors.newFixedThreadPool(procs);

hoge = CompletableFuture.supplyAsync(() -> works.countHoge(), executor);

fuga = CompletableFuture.supplyAsync(() -> works.countFuga(), executor);

chome = CompletableFuture.supplyAsync(() -> works.countChome(), executor);

doAllWorks = CompletableFuture.allOf(hoge, fuga, chome);

workCompletableFutures();

try {

System.out.println(hoge.get());

} catch (ExecutionException | InterruptedException ex) {

Logger.getLogger(TryCompletableFuture.class.getName()).log(Level.SEVERE, null, ex);

}

try {

System.out.println(fuga.get());

} catch (InterruptedException | ExecutionException ex) {

Logger.getLogger(TryCompletableFuture.class.getName()).log(Level.SEVERE, null, ex);

}

try {

System.out.println(chome.get());

} catch (InterruptedException | ExecutionException ex) {

Logger.getLogger(TryCompletableFuture.class.getName()).log(Level.SEVERE, null, ex);

}

CompletableFuture<String> monad = hoge.thenApply(r -> r * r * Math.PI).thenApply(Object::toString);

try {

System.out.println("monad = " + monad.get());

} catch (InterruptedException | ExecutionException ex) {

Logger.getLogger(TryCompletableFuture.class.getName()).log(Level.SEVERE, null, ex);

}

while (true) {

if (doAllWorks.isDone()) {

System.out.println("executor.shutdown()");

executor.shutdown();

try {

if (!executor.awaitTermination(20, TimeUnit.SECONDS)) {

System.out.println("executor.shutdownNow()");

executor.shutdownNow();

break;

}

} catch (InterruptedException ex) {

Logger.getLogger(TryCompletableFuture.class.getName()).log(Level.SEVERE, null, ex);

executor.shutdownNow();

break;

}

break;

}

private static void workCompletableFutures() {

long startTime = System.nanoTime();

System.out.println("<--- START --->");

doAllWorks.thenRun(() -> {

try {

if ((hoge.get() + fuga.get() + chome.get()) == 11) {

System.out.println("<--- DONE --->");

} else {

System.out.println("<--- ERROR --->");

}

} catch (ExecutionException | InterruptedException e) {

throw new RuntimeException(e);

}

long time = System.nanoTime() - startTime;

System.out.println("処理時間は、"

+ (int) (time * 1e-9) / 3_600 + "時間"

+ (int) ((time * 1e-9) / 60) % 60 + "分"

+ (int) (time * 1e-9 % 60) + "秒"

+ Double.toString((time * 1e-9 % 60) % 1).substring(2));

});

}

出力結果は次のようになります。

<— START —>
1
3
7
<— DONE —>
処理時間は、0時間0分6秒9916577070000008
monad = 3.141592653589793
executor.shutdown()

処理時間からそれぞれの処理が平行実行されていることが解りますね。(^_^)

プロファイラで確認してみました。

thenRun() メソッドを使用すると上記のような結果となりますが

thenRunAsync() メソッドというものもあります。

これは ForkJoinPool.commonPool() を使っているようです。

若干 thenRun() メソッドと動作が違います。

こちらはメソッド内の処理が ExecutorService に全て乗らない場合があります。

登録されたタスクが終了した時点で shutdown 開始するとshutdown 開始までに ExecutorService に乗っていれば当然処理されるのですがタイミングが悪いと間に合わず未処理となってしまいます。

37 行目から 60 行目の計算結果取得処理をコメントアウトしてそれぞれ実行してみると良く解ります。

thenRun() メソッドの場合は次のように全て実行され出力されます。

<— START —>
<— DONE —>
executor.shutdown()
処理時間は、0時間0分6秒9965874390000007

thenRunAsync() メソッドを使用した場合は次のように一部処理されずプログラムが終了する場合があります。

<— START —>
executor.shutdown()
<— DONE —>

このあたりは微妙に違うので注意が必要ですね。

ついでに、thenRunAsync() メソッドを使用した場合のプロファイラでみてみました。

ForkJoinPool.commonPool() が存在してますね。

これらの使い分けのシチュエーションが思いつきません。(^_^;)

さて、時間のかかる処理をするのはいいけどあまりにも時間がかかりすぎた場合はデフォルト値を返すようにしたい場合がありますよね。

そんな時のために get(long timeout, TimeUnit unit) メソッドと complete(T value) メソッドが用意されてます。

プログラムに次のコードを追加して動かしてみましょう。

        workCompletableFutures();
        
        try {
            System.out.println(fuga.get(2, TimeUnit.SECONDS));
        } catch (InterruptedException | ExecutionException | TimeoutException ex) {
            Logger.getLogger(TryCompletableFuture.class.getName()).log(Level.SEVERE, null, ex);
            fuga.complete(99);
        }

workCompletableFutures();

try {

System.out.println(fuga.get(2, TimeUnit.SECONDS));

} catch (InterruptedException | ExecutionException | TimeoutException ex) {

Logger.getLogger(TryCompletableFuture.class.getName()).log(Level.SEVERE, null, ex);

fuga.complete(99);

}

fuga.get(2, TimeUnit.SECONDS) 2 秒でタイムアウトして fuga.complete(99) で fuga に 99 を設定します。

もちろん例外もスローされます。

ではプログラムを実行して確認してみましょう。

<— START —>
1
99
7 08, 2013 12:13:28 午前 jp.yucchi.trycompletablefuture.TryCompletableFuture main
SEVERE: null
java.util.concurrent.TimeoutException
at java.util.concurrent.CompletableFuture.timedAwaitDone(CompletableFuture.java:376)
at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1555)
at jp.yucchi.trycompletablefuture.TryCompletableFuture.main(TryCompletableFuture.java:39)

<— ERROR —>
7
処理時間は、0時間0分6秒9896285360000006
monad = 3.141592653589793
executor.shutdown()

ちゃんとタイムアウトして例外を投げてそして fuga に 99 をセットしてますね。

fuga の値が 99 になることによって hoge, fuga, chome の合計値が 11 と等しくならないので <— ERROR —> と判定され出力されてます。

もう、ExecutorService、 Callable、Future インターフェースの時代はオワコンかな？

ざっと確認したけど間違ってる可能性が高いので日本語で誰かが詳しく解説してくれるのを待つとしましょうか。

かなり CompletableFuture っていけてる気がします！

Java8 早くリリースしておくれ！

Hatena タグ: Java

TAGS: Java | 2013年7月8日12:14 AM | Comment : 0

もしかしたら代入に失敗するかもしれない

Java

今日 Twitter で見かけた素晴らしいコードに感動しました。

int a; a = 10; while (a != 10){ a = 10; // もしかしたら代入に失敗するかもしれない } これ実際に見たことあるコードです

— にゃおきゃっと (@nyaocat) May 14, 2013

そこで私も Java8 で創ってみました。

package jp.yucchi.gomi;

import java.util.Optional;

public class Gomi {

    public static void main(String[] args) {
        Optional<Integer> a = Optional.ofNullable(7);
        while(a.orElse(0) != 7){
            a = Optional.ofNullable(7);
        }

        if(a.isPresent()){
            System.out.println(a.get());
        }
    
    }
}

package jp.yucchi.gomi;

import java.util.Optional;

public class Gomi {

public static void main(String[] args) {

Optional<Integer> a = Optional.ofNullable(7);

while(a.orElse(0) != 7){

a = Optional.ofNullable(7);

}

if(a.isPresent()){

System.out.println(a.get());

}

実行結果は次のようになります。
ただ、本当に代入に失敗したかどうかは解りませんｗ

さすがにログをとって何回もとは思いませんでした。
誰かもっと安心できるコードをご存じでしたらご教示お願いいたします。

Hatena タグ: Java

TAGS: Java | 2013年6月26日10:53 AM | Comment : 0

もっと Lambda その１８

Java

昨日のエントリーの解答を載せておきます。

10
8
0
4
2
6

上記のように 0 から 10 までの偶数が表示されます。

出力される順番はプログラムが実行される環境により変わります。

これは parallel() メソッドにより平行ストリームとして処理されるからです。

JavaDOC では下記のようになってます。

java.util.stream.IntStream

public IntStream parallel()

Returns an equivalent stream that is parallel. May return itself, either because the stream was already parallel, or because the underlying stream state was modified to be parallel.

This is an intermediate operation.

戻り値:

a parallel stream

それでは順序よく 0 から 10 までの偶数を表示させるにはどうすればいいでしょうか？

そんな我が儘なあなたに使って欲しいメソッドが用意されてます。

java.util.stream.IntStream

public void forEachOrdered(IntConsumer action)

Performs an action for each element of this stream, guaranteeing that each element is processed in encounter order for streams that have a defined encounter order.

This is a terminal operation.

パラメータ:

action – a non-interfering action to perform on the elements

参照:

IntStream.forEach(IntConsumer)

これを使って昨日のプログラムを変更してみます。

ついでにメソッドリファレンスを使うように変更しました。

package jp.yucchi.tryforeachordered;

import java.util.stream.IntStream;

public class TryforEachOrdered {

    public static void main(String[] args) {
        IntStream.rangeClosed(0, 10).parallel()
                .filter(e -> (e & 1) == 0)
                .forEachOrdered(System.out::println);
    }
    
}

package jp.yucchi.tryforeachordered;

import java.util.stream.IntStream;

public class TryforEachOrdered {

public static void main(String[] args) {

IntStream.rangeClosed(0, 10).parallel()

.filter(e -> (e & 1) == 0)

.forEachOrdered(System.out::println);

}

実行結果は期待通りに順序よく出力されます。

0
2
4
6
8
10

検証はしてないのですがコストが高くなるようなので使いどころを誤らないようにしなければいけないようです。

簡単なパズルでしたけどなんでもいいから平行ストリーム使っちゃえ！ってやってたらはまる可能性がありますね。（私のような単純で純粋なひとはｗ）

Hatena タグ: Java

TAGS: Java | 2013年6月19日3:34 AM | Comment : 0

もっと Lambda その１７

Java

今日も　Java8 ネタです。

すでに Lambda のメーリングリストでやりとりされていたネタを Java パズルとして出題します。

次のプログラムを実行するとどうなるでしょうか？

超ウルトラ簡単なパズルです。

package jp.yucchi.tryforeachordered;

import java.util.stream.IntStream;

public class TryforEachOrdered {

    public static void main(String[] args) {
        IntStream.rangeClosed(0, 10).parallel()
                .filter(e -> (e & 1) == 0)
                .forEach(e -> System.out.println(e));
    }
    
}

package jp.yucchi.tryforeachordered;

import java.util.stream.IntStream;

public class TryforEachOrdered {

public static void main(String[] args) {

IntStream.rangeClosed(0, 10).parallel()

.filter(e -> (e & 1) == 0)

.forEach(e -> System.out.println(e));

}

答えは気が向いたら投稿するかもしれません。

あしからず・・・

Hatena タグ: Java

TAGS: Java | 2013年6月18日5:42 AM | Comment : 0

もっと Lambda その１６

Java

Java Platform, Standard Edition 8 Early Access with Lambda Support b94 の optional クラスに filter map flatMap など愉快な仲間達が追加されたようです。

早速試してみました。

ネタ元はこちらです。

Java8でのプログラムの構造を変えるOptional、ただしモナドではない

この記事ではモナドについて触れられてますが私はモナドさっぱり解りません。

それって最中の親戚で甘くて美味しいの？ってレベルです。(^_^;)

それではまるっとコードを美味しくいただいて動くかどうか試してみます。

コードはいつものデータを利用します。

無駄に長いです。

<– Person –>
柴田恭平, 61歳, Gender: MALE   体重 : 70   評価 : 8
壇蜜, 32歳, Gender: FEMALE   体重 : 60   評価 : 6
北川景子, 26歳, Gender: FEMALE   体重 : 55   評価 : 7
綾瀬はるか, 28歳, Gender: FEMALE   体重 : 50   評価 : 4
佐々木希, 25歳, Gender: FEMALE   体重 : 48   評価 : 9
剛力彩芽, 20歳, Gender: FEMALE   体重 : 45   評価 : 6
小栗旬, 30歳, Gender: MALE   体重 : 65   評価 : 3
堀北真希, 24歳, Gender: FEMALE   体重 : 45   評価 : 10
武井咲, 19歳, Gender: FEMALE   体重 : 50   評価 : 5
市原隼人, 26歳, Gender: MALE   体重 : 67   評価 : 2
深田恭子, 30歳, Gender: FEMALE   体重 : 50   評価 : 8

上記のリストで一番若い男性のもとへ一番若い女性がお嫁入りするとしてその女性の新しい姓名を表示させてみます。

ほげほげ＠ちょめちょめ　ってね。

package jp.yucchi.tryoptional;

import java.time.LocalDate;
import java.time.Period;

public class Person {

    public enum Sex {

        MALE, FEMALE
    }
    String firstName;
    String lastName;
    LocalDate birthday;
    Sex gender;
    int weight;
    int evaluation;

    public Person(String firstName, String lastName, LocalDate birthday, Sex gender, int weight, int evaluation) {
        this.firstName = firstName;
        this.lastName = lastName;
        this.birthday = birthday;
        this.gender = gender;
        this.weight = weight;
        this.evaluation = evaluation;
    }

    public String getFirstName() {
        return firstName;
    }

    public String getLastName() {
        return lastName;
    }

    public Sex getGender() {
        return gender;
    }

    public int getAge() {
        return Period.between(birthday, LocalDate.now()).getYears();
    }

    void printPerson() {
        System.out.println(firstName + " " + lastName + ", " + this.getAge() + "歳" + ", Gender: "
                + this.getGender() + "   体重 : " + this.getWeight() + "   評価 : " + this.getEvaluation());
    }

    public int getWeight() {
        return weight;
    }

    public void setWeight(int weight) {
        this.weight = weight;
    }

    public int getEvaluation() {
        return evaluation;
    }

    public void setEvaluation(int evaluation) {
        this.evaluation = evaluation;
    }

}

package jp.yucchi.tryoptional;

import java.time.LocalDate;

import java.time.Period;

public class Person {

public enum Sex {

MALE, FEMALE

}

String firstName;

String lastName;

LocalDate birthday;

Sex gender;

int weight;

int evaluation;

public Person(String firstName, String lastName, LocalDate birthday, Sex gender, int weight, int evaluation) {

this.firstName = firstName;

this.lastName = lastName;

this.birthday = birthday;

this.gender = gender;

this.weight = weight;

this.evaluation = evaluation;

}

public String getFirstName() {

return firstName;

}

public String getLastName() {

return lastName;

}

public Sex getGender() {

return gender;

}

public int getAge() {

return Period.between(birthday, LocalDate.now()).getYears();

}

void printPerson() {

System.out.println(firstName + " " + lastName + ", " + this.getAge() + "歳" + ", Gender: "

+ this.getGender() + " 体重 : " + this.getWeight() + " 評価 : " + this.getEvaluation());

}

public int getWeight() {

return weight;

}

public void setWeight(int weight) {

this.weight = weight;

}

public int getEvaluation() {

return evaluation;

}

public void setEvaluation(int evaluation) {

this.evaluation = evaluation;

}

package jp.yucchi.tryoptional;

import java.time.LocalDate;
import java.util.ArrayList;
import static java.util.Comparator.comparing;
import java.util.List;
import java.util.Optional;
import java.util.function.ToIntFunction;

public class TryOptional {

    public static void main(String[] args) {

        List<Person> person = new ArrayList<>();

        person.add(new Person("柴田", "恭平", LocalDate.of(1951, 8, 18), Person.Sex.MALE, 70, 8));
        person.add(new Person("壇", "蜜", LocalDate.of(1980, 12, 3), Person.Sex.FEMALE, 60, 6));
        person.add(new Person("北川", "景子", LocalDate.of(1986, 8, 22), Person.Sex.FEMALE, 55, 7));
        person.add(new Person("綾瀬", "はるか", LocalDate.of(1985, 3, 24), Person.Sex.FEMALE, 50, 4));
        person.add(new Person("佐々木", "希", LocalDate.of(1988, 2, 8), Person.Sex.FEMALE, 48, 9));
        person.add(new Person("剛力", "彩芽", LocalDate.of(1992, 8, 27), Person.Sex.FEMALE, 45, 6));
        person.add(new Person("小栗", "旬", LocalDate.of(1982, 12, 26), Person.Sex.MALE, 65, 3));
        person.add(new Person("堀北", "真希", LocalDate.of(1988, 10, 6), Person.Sex.FEMALE, 45, 10));
        person.add(new Person("武井", "咲", LocalDate.of(1993, 12, 25), Person.Sex.FEMALE, 50, 5));
        person.add(new Person("市原", "隼人", LocalDate.of(1987, 2, 6), Person.Sex.MALE, 67, 2));
        person.add(new Person("深田", "恭子", LocalDate.of(1982, 11, 2), Person.Sex.FEMALE, 50, 8));
        
        Optional<String> byYoungestMan_firstName;
        Optional<String> byYoungestWoman_lastName;
        
        ToIntFunction<Person> byAge = p -> p.getAge();

        byYoungestMan_firstName = person.stream()
                .filter(e -> e.getGender() == Person.Sex.MALE)
                .sorted(comparing(byAge))
                .map(Person::getFirstName)
                .findFirst();

        byYoungestWoman_lastName = person.stream()
                .filter(e -> e.getGender() == Person.Sex.FEMALE)
                .sorted(comparing(byAge))
                .map(Person::getLastName)
                .findFirst();

        if (byYoungestMan_firstName.isPresent()) {
            System.out.println(byYoungestMan_firstName.get());
        }
        if (byYoungestWoman_lastName.isPresent()) {
            System.out.println(byYoungestWoman_lastName.get());
        }

        Optional<String> fullName = byYoungestMan_firstName.flatMap(fn -> byYoungestWoman_lastName.map(ln -> String.join("@", fn, ln)));
        if (fullName.isPresent()) {
            System.out.println(fullName.get());        
        }
       
    }

}

package jp.yucchi.tryoptional;

import java.time.LocalDate;

import java.util.ArrayList;

import static java.util.Comparator.comparing;

import java.util.List;

import java.util.Optional;

import java.util.function.ToIntFunction;

public class TryOptional {

public static void main(String[] args) {

List<Person> person = new ArrayList<>();

person.add(new Person("柴田", "恭平", LocalDate.of(1951, 8, 18), Person.Sex.MALE, 70, 8));

person.add(new Person("壇", "蜜", LocalDate.of(1980, 12, 3), Person.Sex.FEMALE, 60, 6));

person.add(new Person("北川", "景子", LocalDate.of(1986, 8, 22), Person.Sex.FEMALE, 55, 7));

person.add(new Person("綾瀬", "はるか", LocalDate.of(1985, 3, 24), Person.Sex.FEMALE, 50, 4));

person.add(new Person("佐々木", "希", LocalDate.of(1988, 2, 8), Person.Sex.FEMALE, 48, 9));

person.add(new Person("剛力", "彩芽", LocalDate.of(1992, 8, 27), Person.Sex.FEMALE, 45, 6));

person.add(new Person("小栗", "旬", LocalDate.of(1982, 12, 26), Person.Sex.MALE, 65, 3));

person.add(new Person("堀北", "真希", LocalDate.of(1988, 10, 6), Person.Sex.FEMALE, 45, 10));

person.add(new Person("武井", "咲", LocalDate.of(1993, 12, 25), Person.Sex.FEMALE, 50, 5));

person.add(new Person("市原", "隼人", LocalDate.of(1987, 2, 6), Person.Sex.MALE, 67, 2));

person.add(new Person("深田", "恭子", LocalDate.of(1982, 11, 2), Person.Sex.FEMALE, 50, 8));

Optional<String> byYoungestMan_firstName;

Optional<String> byYoungestWoman_lastName;

ToIntFunction<Person> byAge = p -> p.getAge();

byYoungestMan_firstName = person.stream()

.filter(e -> e.getGender() == Person.Sex.MALE)

.sorted(comparing(byAge))

.map(Person::getFirstName)

.findFirst();

byYoungestWoman_lastName = person.stream()

.filter(e -> e.getGender() == Person.Sex.FEMALE)

.sorted(comparing(byAge))

.map(Person::getLastName)

.findFirst();

if (byYoungestMan_firstName.isPresent()) {

System.out.println(byYoungestMan_firstName.get());

}

if (byYoungestWoman_lastName.isPresent()) {

System.out.println(byYoungestWoman_lastName.get());

}

Optional<String> fullName = byYoungestMan_firstName.flatMap(fn -> byYoungestWoman_lastName.map(ln -> String.join("@", fn, ln)));

if (fullName.isPresent()) {

System.out.println(fullName.get());

}

実行結果は以下のようになります。

市原
咲
市原@咲

期待通りに動いてるけどこれが可能になることが Java な人には重要なことなんだろうか？

モナドを美味しくいただけくことができない私にはイマイチ理解ができないです。

もしこれが重要なことだとしたらそのうち誰かが記事にして熱く語ってくれるだろう。

Hatena タグ: Java

TAGS: Java | 2013年6月14日6:07 AM | Comment : 0

« 古い記事新しい記事 »

ゆっちのBlog

CompletableFuture を解らないまま試してみた

もしかしたら代入に失敗するかもしれない

もっと Lambda その１８

もっと Lambda その１７

もっと Lambda その１６

Recent Comments

Java

NetBeans

カテゴリー

アーカイブ

RSS FEED

ねこび～ん

メタ情報

ゆっちのカレンダー

2024年10月
月	火	水	木	金	土	日
« 1月
	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

ゆっちのBlog

CompletableFuture を解らないまま試してみた

もしかしたら代入に失敗するかもしれない

もっと Lambda その１８

もっと Lambda その１７

もっと Lambda その１６

Popular post ranking

Recent Comments

Java

NetBeans

カテゴリー

アーカイブ

RSS FEED

ねこび～ん

メタ情報

ゆっちのカレンダー