2021年12月3日 / 最終更新日 : 2021年12月3日 akiyama おすすめ

ファスティング体験記

適度な運動、バランスのよい食事を心がけて生活・・・したいものですが、なかなか難しいのが現実です。私はおなかの調子が悪くなることが続いた時期、改善策を調べていた際に目にしたのが「ファスティング」。ダイ […]

2021年12月1日 / 最終更新日 : 2021年12月1日 akiyama おすすめ

おうちコーヒーのススメ

最近は急激に冷え込み、温かいコーヒーが美味しい季節になってきました。皆さんはコーヒーをよく飲むでしょうか。私は少し前に家でコーヒーを入れるため、豆を挽くコーヒーミルとコーヒードリッパーを購入しました。以前はインスタ […]

2021年11月15日 / 最終更新日 : 2021年11月15日 tmiyata CSR

【宮田莉朋選手】スーパーGT2度目のポール獲得

モータースポーツシーズンもいよいよ終盤戦となりました。しかしながら莉朋選手にとりまして、スーパーフォーミュラシーズンでは苦しい展開のまま終了しました。シリーズランキング10位と不本意な結果でしたが、得るものも多く来シ […]

2021年11月15日 / 最終更新日 : 2021年12月1日 akiyama 技術講習

複数スレッドで平行処理し、順序そのままで結果を格納する

こんにちわ、猫好きリーマンのほげPGです。今回は複数スレッドで平行処理し、要求時の順序で結果を配列に格納するコードを紹介します。ソースコード

import java.util.Arrays;
import java.util.List;
import java.util.Random;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.stream.Collectors;

public class Hoge {

    public static void main(String[] args) throws Exception {
        log("start ...");
        ExecutorService streamPool = Executors.newFixedThreadPool(10);  //①
        List<String> requests = Arrays.asList(new String[] {"11", "22", "33", "44", "55"});  //②
        String[] array = new String[requests.size()];  //③
        try {
            CountDownLatch latch = new CountDownLatch(requests.size());  //④
            int i = 0;
            for (String val : requests) {
                Integer x = i++;           //⑤
                streamPool.submit(() -> {  //⑥
                    log("start..." + x);
                    try {
                        array[x] = doHoge(val);  //⑦
                    } catch (Exception e) {
                        log(e.toString());
                    } finally {
                        latch.countDown();
                    }
                    log("end..." + x);
                });
            }
            latch.await();
        } finally {
            streamPool.shutdown();
        }
        List<String> results = Arrays.stream(array)
        .filter(pi -> pi != null)       //⑧
        .collect(Collectors.toList());  //⑨
        log(results.toString());
        log("end ...");
    }

    static Random rand = new Random();
    static String doHoge(String v) throws InterruptedException {
        if ("44".equals(v)) throw new RuntimeException("test");
        int n = rand.nextInt(10);
        Thread.sleep(n * 1000);
        return v + "-" + n;
    }
    public static void log(String msg) {
        System.out.println(msg);
    }
}