新日撸java三百行` 新手小白java学习记录 `Day1

新日撸java三百行新手小白java学习记录

Day1 模拟多线程回调机制


文章目录

  • 新日撸java三百行` 新手小白java学习记录 `
  • 前言
  • 一 、模拟异步机制
  • 提出问题
  • 解决方案


前言

古人称长江为江,黄河为河。长江水清,黄河水浊,长江在流,黄河也在流。 长江之水灌溉了两岸数省之田地,黄河之水也灌溉了数省两岸之田地,只能不因水清而偏用,也只能不因水浊而偏废,自古皆然。


一 、模拟异步机制

提出问题

众所周知,java实现多线程可以实现Runnable、Callable两个接口,两者区别在于有无返回值。
目标:探究Callable的返回值如何返回的
问题:主线程中派生一个线程A执行有返回值的任务,如何解决主子线程时间差。

解决方案

使用一个已知的对象来承接返回值,命名为MyCompletableFuture。

  • 1.定义自已的任务实现接口myable类似Callable接口
public interface Myable<T> {
    T my();
}
  • 2.创建MyCompletableFuture类
    核心类,目的是截断子线程的返回值,使用该类代替子线程的返回值。
    大概逻辑:持有任务接口(符合里式替换原则),持有任务的返回值result, 持有标志位isComplete判断任务是否完成,持有还有一个自定义回调接口CallBack。
    – get()方法,调用该方法的线程会尝试获取任务的结果,此时有两种情况:任务完成和未完成。
    – submit()方法开启一个线程,调用任务接口的my方法执行任务并将返回值赋值给result,完成后调用Complete()方法
    – Complete()方法将标志位变成true标明任务完成;唤醒等待中的线程;调用回调。
public class MyCompletableFuture<T> {

    private Myable<T> myable;
    private T result;
    private Exception exception;

    private boolean isComplete = false;

    // private List<Function<T , ?>> callbacks = new ArrayList();

    private List<CallBack<T , ?>> callbacks = new ArrayList();
    public MyCompletableFuture() {
    }

    public MyCompletableFuture(Myable<T> myable) {
        this.myable = myable;
    }

    /**
     * 线程的启动方法 , 运行一个Myable的实现类 , 并接受返回值复制给当前类属性 , 而后调用Complete()方法。
     */
    public void submit(){
        new Thread(
                ()->{
                    this.result = myable.my();
                    try {
                        Complete();
                    } catch (Exception e) {
                        throw new RuntimeException(e);
                    }
                }
        ).start();
    }

    /**
     * 当此方法被调用,说明返回值已经被成功接收 , 届时可以调整状态属性 , 唤醒调用get()的其他线程 , 执行回调。
     * @throws Exception
     */
    private synchronized void  Complete() throws Exception {

        // this.result = result;
        isComplete = true;
        notifyAll();
        executeCallbacks();
    }

    public synchronized void completeExceptionally (Exception e){
        this.exception = e;
        this.isComplete = true;
        notifyAll();
        executeCallbacks();
    }

    /**
     * 判断返回值是否就绪 , 如果就绪则调用列表中的订阅者的回调函数 , 否则订阅该列表。
     * @param callback : 实现CallBack接口的回调方法
     * @return
     */
    public synchronized MyCompletableFuture<Void> thenApply(CallBack<T , ?> callback){
        if(isComplete){
            if(exception != null){
                throw new RuntimeException(exception);
            }
            callback.callBack(result);
        }
        else {
            callbacks.add(callback);
        }
        return new MyCompletableFuture<>();
    }


    /**
     * 发布订阅模式执行回调。
     */
    public synchronized void executeCallbacks(){
        for (CallBack<T, ?> callback: callbacks
             ) {
            callback.callBack(result);
        }

        callbacks.clear();
    }


    /**
     * 获取返回值的方法,如果准备就绪则获取,否则wait();
     * @return
     * @throws Exception
     */
    public synchronized T get() throws  Exception{
        if(!isComplete){
            wait();
        }

        if(exception != null){
            throw exception;
        }
        return result;
    }
}
  • 3.回调实现逻辑
    – 定义回调接口CallBack(函数式编程接口)
public interface CallBack<T , R> {
    R callBack(T t);
}

– 使用发布订阅模式在MyCompletableFuture中持有了一个CallBack类型的List,实现一个注册方法thenApply,当需要子线程结果的时候就调用thenApply方法

  • 4.使用案例
    定义任务类实现任务接口,任务就是对一个数组排序
class AsyncProcessor implements Myable<int[]>{

    int nums[] ;

    public AsyncProcessor(int[] nums) {
        this.nums = nums;
    }

    @Override
    public int[] my() {
        try {
            Thread.sleep(1000);
            System.out.println("耗时排序中.......");
            Thread.sleep(2000);


            Arrays.sort(nums);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
        return nums;
    }
}

主函数 将任务交给MyCompletableFuture

public class Main {
    public static void main(String[] args) throws Exception {
        int nums[] = new int[]{1,5,7,8,1,5,78,1,5,1};
        AsyncProcessor processor = new AsyncProcessor(nums);


        MyCompletableFuture<int[]> futureResult = new MyCompletableFuture<>(processor);

        futureResult.submit();

        futureResult.thenApply(result -> {
            System.out.println("最大值: " + result[nums.length-1]);
            return null; // 返回值为 void
        });

        futureResult.thenApply(result -> {
            System.out.println("最小值: " + result[0]);
            return null; // 返回值为 void
        });


        futureResult.thenApply(result -> {
            System.out.println("排序结果: " + Arrays.toString(result));
            return null; // 返回值为 void
        });
        // 在主线程继续执行其他操作
        System.out.println("请求已发送,等待处理结果...");

        // 获取结果(会阻塞直到完成)
        try {
            futureResult.get(); // 获取处理结果,等待完成
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

在这里插入图片描述

总结:主线程想要不阻塞继续执行,必然会有一个已知的类型对象来接受返回值,进而将真正的返回值隐藏在该对象中。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/915424.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

【Unity Bug 随记】unity version control 报 xx is not in a workspace.

可能原因是更改了仓库或者项目名称。 解决办法就是重置Unity Version Control&#xff0c;去Hub disconnect 然后重新connect cloud和UVC UVC可能连不上&#xff0c;直接进入项目就行&#xff0c;打开版本管理标签会让你重新连工作区&#xff0c;选择你的仓库和工作区 然后In…

Go语言入门教案

文章目录 一、教学目标二、教学重难点&#xff08;一&#xff09;重点&#xff08;二&#xff09;难点 三、教学方法四、教学过程&#xff08;一&#xff09;Go语言简介&#xff08;二&#xff09;环境搭建1. 下载和安装Go语言开发环境2. 配置Go语言环境变量3. 命令行查看Go语言…

[2024最新] java八股文实用版(附带原理)---java集合篇

介绍一下常见的list实现类&#xff1f; ArrayList 线程不安全&#xff0c;内部是通过数组实现的&#xff0c;继承了AbstractList&#xff0c;实现了List&#xff0c;适合随机查找和遍历&#xff0c;不适合插入和删除。排列有序&#xff0c;可重复&#xff0c;当容量不够的时候…

7天用Go从零实现分布式缓存GeeCache(学习)(3)

目录结构 ├── geecache │ ├── byteview.go │ ├── cache.go │ ├── consistenthash │ │ ├── consistenthash.go │ │ └── consistenthash_test.go │ ├── geecache.go │ ├── go.mod │ ├── http.go │ ├── lru │ …

OpenHarmony-1.启动流程

OpenHarmony启动流程 1.kernel的启动 流程图如下所示&#xff1a;   OpenHarmony(简称OH)的标准系统的底层系统是linux&#xff0c;所以调用如下代码&#xff1a; linux-5.10/init/main.c: noinline void __ref rest_init(void) {struct task_struct *tsk;int pid;rcu_sch…

HTB:Precious[WriteUP]

目录 连接至HTB服务器并启动靶机 使用nmap对靶机TCP端口进行开放扫描 使用curl访问靶机80端口 使用ffuf爆破一下子域 使用浏览器访问该域名 使用curl访问该域名响应头 使用exiftool工具查看该pdf信息 横向移动 USER_FLAG&#xff1a;adf5793a876a190f0c08b3b6247cec32…

jsmind 思维导图 + monaco-editor + vue3 + ts

Index.vue: <template><div class"m-jsmind-wrap"><div class"m-jsmind-header"><el-button type"primary" click"() > handleReset()">重置</el-button><el-button type"primary" cl…

在arm64架构下, Ubuntu 18.04.5 LTS 用命令安装和卸载qt4、qt5

问题&#xff1a;需要在 arm64下安装Qt&#xff0c;QT源码编译失败以后&#xff0c;选择在线安装&#xff01; 最后安装的版本是Qt5.9.5 和QtCreator 4.5.2 。 一、ubuntu安装qt4的命令(亲测有效)&#xff1a; sudo add-apt-repository ppa:rock-core/qt4 sudo apt updat…

AIGC学习笔记(5)——AI大模型开发工程师

文章目录 AI大模型开发工程师004 垂直领域的智能在线搜索平台1 智能在线搜索平台需求分析大模型不够“聪明”增强大模型的方式需求分析2 智能在线搜索平台方案设计方案设计技术选型大模型版本GLM-4大模型注册使用Google Cloud平台注册创建可编程的搜索引擎3 智能在线搜索平台代…

【React】状态管理之Redux

&#x1f308;个人主页: 鑫宝Code &#x1f525;热门专栏: 闲话杂谈&#xff5c; 炫酷HTML | JavaScript基础 ​&#x1f4ab;个人格言: "如无必要&#xff0c;勿增实体" 文章目录 状态管理之Redux引言1. Redux 的核心概念1.1 单一数据源&#xff08;Single Sou…

Unity类银河战士恶魔城学习总结(P124 CharacterStats UI玩家的UI)

【Unity教程】从0编程制作类银河恶魔城游戏_哔哩哔哩_bilibili 教程源地址&#xff1a;https://www.udemy.com/course/2d-rpg-alexdev/ 本章节实现了玩家属性栏&#xff0c;仓库&#xff0c;物品栏UI的制作 UI_StatSlot.cs 这个脚本是用来在Unity的UI上显示玩家属性&#xf…

蓝桥杯每日真题 - 第7天

题目&#xff1a;&#xff08;爬山&#xff09; 题目描述&#xff08;X届 C&C B组X题&#xff09; 解题思路&#xff1a; 前缀和构造&#xff1a;为了高效地计算子数组的和&#xff0c;我们可以先构造前缀和数组 a&#xff0c;其中 a[i] 表示从第 1 个元素到第 i 个元素的…

Llama旋转位置编码代码实现及详解

旋转位置编码RoPE 在旋转位置编码与Transformer和BERT之间的区别中介绍了旋转位置编码&#xff08;RoPE&#xff09;的特点和优势&#xff0c;这种输入长度动态可变的优势使得在Llama编码时&#xff0c;不需要掩码将多余的嵌入掩住。为了详细了解RoPE是如何实现的&#xff0c;…

WebSocket和HTTP协议的性能比较与选择

WebSocket和HTTP协议的性能比较与选择 引言&#xff1a; 在web应用开发中&#xff0c;无论是实时聊天应用、多人在线游戏还是实时数据传输&#xff0c;网络连接的稳定性和传输效率都是关键要素之一。目前&#xff0c;WebSocket和HTTP是两种常用的网络传输协议&#xff0c;它们…

WebRTC项目一对一视频

开发步骤 1.客户端显示界面 2.打开摄像头并显示到页面 3.websocket连接 4.join、new-peer、resp-join信令实现 5.leave、peer-leave信令实现 6.offer、answer、candidate信令实现 7.综合调试和完善 1.客户端显示界面 步骤&#xff1a;创建html页面 主要是input、button、vide…

GIS基础知识:WKT格式、WKB格式

什么是WKT格式&#xff1f; WKT&#xff08;Well-Known Text&#xff09;是一种用于描述地理空间几何对象的文本格式。 这种格式是由Open Geospatial Consortium&#xff08;OGC&#xff09;定义并维护的一种开放标准&#xff0c;主要用于在不同的GIS系统和数据库之间交换空间…

力扣(LeetCode)611. 有效三角形的个数(Java)

White graces&#xff1a;个人主页 &#x1f649;专栏推荐:Java入门知识&#x1f649; &#x1f439;今日诗词:雾失楼台&#xff0c;月迷津渡&#x1f439; ⛳️点赞 ☀️收藏⭐️关注&#x1f4ac;卑微小博主&#x1f64f; ⛳️点赞 ☀️收藏⭐️关注&#x1f4ac;卑微小博主…

Mac Nginx 前端打包部署

安装homebrew /bin/zsh -c "$(curl -fsSL https://gitee.com/cunkai/HomebrewCN/raw/master/Homebrew.sh)" 安装Nginx brew install nginx nginx相关命令 nginx启动命令&#xff1a;nginx nginx -s reload #重新加载配置 nginx -s reopen #重启 nginx -s stop #…

利用VMware workstation pro 17安装 Centos7虚拟机以及修改网卡名称

通过百度网盘分享的文件&#xff1a;安装虚拟机必备软件 链接&#xff1a;https://pan.baidu.com/s/1rbYhDh8x1hTzlSNihm49EA?pwdomxy 提取码&#xff1a;omxy 123网盘 https://www.123865.com/s/eXPrVv-UsKch 提取码:eNcy 先自行安装好VMware workstation pro 17 设置虚拟机…

《实时流计算系统设计与实现》-Part 2-笔记

做不到实时 做不到实时的原因 实时计算很难。通过增量计算的方式来间接获得问题的&#xff08;伪&#xff09;实时结果&#xff0c;即使这些结果带有迟滞性和近似性&#xff0c;但只要能够带来尽可能最新的信息&#xff0c;那也是有价值的。 原因可分成3个方面&#xff1a; …