标签：static 场景 String printTimeAndThread SmallTools add CompletableFuture 使用 sleep

例题来源于 b站灰灰

https://space.bilibili.com/51950540/dynamic?spm_id_from=444.41.0.0

场景1 主线程等待子线程执行完毕后并获取结果而后执行

public class Test {
    public static void main(String[] args) {
        SmallTools.printTimeAndThread("小白进入餐厅");
        SmallTools.printTimeAndThread("小白点了 番茄炒蛋+一碗米饭");
        CompletableFuture<String> cf1 = CompletableFuture.supplyAsync(() -> {
            SmallTools.printTimeAndThread("厨师炒菜");
            SmallTools.sleep(200);
            SmallTools.printTimeAndThread("厨师打饭");
            SmallTools.sleep(300);
            return "番茄鸡蛋+米饭做好啦";
        });
        SmallTools.printTimeAndThread("小白在打王者");
        SmallTools.printTimeAndThread(String.format("%s,小白开吃", cf1.join()));
    }

    static class SmallTools {
        public static void sleep(long millis) {
            try {
                Thread.sleep(millis);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

        public static String printTimeAndThread(String tag) {
            String result = new StringJoiner("\t|\t")
                    .add(String.valueOf(System.currentTimeMillis()))
                    .add(String.valueOf(Thread.currentThread().getId()))
                    .add(Thread.currentThread().getName())
                    .add(tag)
                    .toString();
            System.out.println(result);
            return result;
        }
    }
}

• supplyAsync 用来开启一个异步任务
  其中 CompletableFuture.supplyAsync 用来开启一个子线程，其方法执行完毕后返回一个结果，主线程可以通过调用 cf1.join() 来获取执行结果

场景2 主线程等待多个子线程执行完毕后执行，而子线程分先后顺序，线程1需要等待线程2执行完毕后再执行

public class Test {
    public static void main(String[] args) {
        SmallTools.printTimeAndThread("小白进入餐厅");
        SmallTools.printTimeAndThread("小白点了 番茄炒蛋+一碗米饭");
        CompletableFuture<String> cf1 = CompletableFuture.supplyAsync(() -> {
            SmallTools.printTimeAndThread("厨师炒菜");
            SmallTools.sleep(1200);
            return "番茄鸡蛋";
        }).thenCompose(dish -> CompletableFuture.supplyAsync(() -> {
            SmallTools.printTimeAndThread("服务员打饭");
            SmallTools.sleep(300);
            return dish + "+米饭做好啦";
        }));
        SmallTools.printTimeAndThread("小白在打王者");
        SmallTools.printTimeAndThread(String.format("%s,小白开吃", cf1.join()));
    }

    static class SmallTools {
        public static void sleep(long millis) {
            try {
                Thread.sleep(millis);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

        public static String printTimeAndThread(String tag) {
            String result = new StringJoiner("\t|\t")
                    .add(String.valueOf(System.currentTimeMillis()))
                    .add(String.valueOf(Thread.currentThread().getId()))
                    .add(Thread.currentThread().getName())
                    .add(tag)
                    .toString();
            System.out.println(result);
            return result;
        }
    }
}

• thenCompose 用来连接两个任务
  第二个任务需要获取第一个任务的返回结果后返回

场景3 子线程等待两个子线程执行完毕后，再将这两个子线程的执行结果统一返回

public class Test {
    public static void main(String[] args) {
        SmallTools.printTimeAndThread("小白进入餐厅");
        SmallTools.printTimeAndThread("小白点了 番茄炒蛋+一碗米饭");
        CompletableFuture<String> cf1 = CompletableFuture.supplyAsync(() -> {
            SmallTools.printTimeAndThread("厨师炒菜");
            SmallTools.sleep(200);
            return "番茄鸡蛋";
        }).thenCombine(CompletableFuture.supplyAsync(() -> {
            SmallTools.printTimeAndThread("服务员煮饭");
            SmallTools.sleep(200);
            return "";
        }), (dish, rice) -> {
            SmallTools.printTimeAndThread("服务员打饭");
            return dish + rice;
        });
        SmallTools.printTimeAndThread("小白在打王者");
        SmallTools.printTimeAndThread(String.format("%s,小白开吃", cf1.join()));
    }

    static class SmallTools {
        public static void sleep(long millis) {
            try {
                Thread.sleep(millis);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

        public static String printTimeAndThread(String tag) {
            String result = new StringJoiner("\t|\t")
                    .add(String.valueOf(System.currentTimeMillis()))
                    .add(String.valueOf(Thread.currentThread().getId()))
                    .add(Thread.currentThread().getName())
                    .add(tag)
                    .toString();
            System.out.println(result);
            return result;
        }
    }
}

• thenCombine 连接两个子线程，而后将两个线程的执行结果合并后统一输入

标签：static,场景,String,printTimeAndThread,SmallTools,add,CompletableFuture,使用,sleep
来源： https://www.cnblogs.com/iullor/p/15868713.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。