网络编程

一、

1.1、软件结构

C/S 结构：Client/Server，客户端服务器结构。（QQ，迅雷）

B/S 结构：Browser/Server，浏览器服务器结构。（Chrome，火狐）

展开全文 >>

Java集合

Java 中的集合容器简介

1、Java 中常用的容器类介绍

  • Collection 接口和 Map 接口是所有集合框架的父接口。

  • Collection 集合的子接口有 List、Set、Queue 三种子接口，比较常用的是 List 接口 和 Set 接口。

    List 接口 的实现类主要有：ArrayList（线程不安全）、LinkedList、Stack 以及 Vector（线程安全）等；

    Set 接口 的实现类主要有：HashSet、TreeSet、LinkedHashSet 等。

    Queue 接口：BlockingQueue

  • Map 接口 的实现类主要有：HashMap、TreeMap、Hashtable、LinkedHashMap、ConcurrentHashMap 以及 Properties 等。

展开全文 >>

多线程整理

1、什么是线程

很多多线程是模拟出来的，真正的多线程是指有多个cpu，即多核，如服务器，如果是模拟出来的多线程，即在一个 cpu 的情况下，在同一个时间点，cpu 只能执行一个代码，因为切换的很快，所以就有同时执行的错觉。

展开全文 >>

CompletableFuture学习 

1
2
3
4
感谢
https://www.zhihu.com/question/318472639/answer/652254785
https://zhuanlan.zhihu.com/p/344431341
https://www.bilibili.com/video/BV1ui4y1T7xf

0、准备

ListenableFuture 是由 Google Guava工具包提供的 Future 扩展类，随后，JDK 在 1.8 版本中马上也提供了类似这样的类，在 9 中进一步增强，这就是 CompletableFuture。CompletableFuture 同样实现了 Future 接口，并在此基础上进行了丰富的扩展，弥补了 Future 的局限性，是对 Future 的扩展和增强，同时 CompletableFuture 实现了对任务编排的能力。

展开全文 >>

Future学习

0、同步和异步

Callable 和 Future 在 JDK1.5 之后开始提供

  • 同步：同步是指一个进程在执行某个请求的时候，如果该请求需要一段时间才能返回信息，那么这个进程会一直等待下去，直到收到返回信息才继续执行下去。
  • 异步：异步是指进程不需要一直等待下去，而是继续执行下面的操作，不管其他进程的状态，当有信息返回的时候会通知进程进行处理，这样可以提高执行效率。

Future 模式的核心思想是能够让主线程将原来需要同步等待的这段时间用来做其他的事情，因为可以异步获得执行结果，所以不用一直同步等待去获得执行结果。

展开全文 >>

ListenableFuture学习

ListenableFuture 是 Guava 工具包提供的 Future 扩展类，是可以监听的 Future，是对 Java 原生Future 的扩展增强。

老版 Future 模式一个最大的问题是需要获取结果做后续处理操作的时候，还是需要阻塞等待。这样的话和同步调用方式就没有多大区别了。而 ListenableFuture 和 CompletableFuture 对于这种情况提供了很多易用的 API。

如果使用 ListenableFuture，Guava 会帮助检测 Future 是否完成了，如果完成就自动调用回调函数，这样可以减少并发程序的复杂度。

ListenableFuture 接口扩展了 Future 接口，增加了 addListener 方法，该方法在给定的 excutor 上注册一个监听器，当计算完成时会马上调用该监听器。虽然不能够确保监听器执行的顺序，但可以确保在计算完成时马上被调用。

image-20230109195031470

1、ListenableFuture 的初始化

addListener()：注册回调函数，在实际使用时可能不会直接使用这个接口，因为这个接口只能传 Runnable 实例，Futures 类提供了另一个 addCallback 方法。

1
2
3
public interface ListenableFuture<V> extends Future<V> {
    void addListener(Runnable listener, Executor executor);
}
1
2
3
4
5
6
7
8
class Task implements Callable<String> {
    @Override
    public String call() throws Exception {
        TimeUnit.SECONDS.sleep(1);
//        int a = 1 / 0;	// 异常
        return "task done";
    }
}
1
2
3
4
5
6
7
8
public void lisFuture() throws ExecutionException, InterruptedException {
    ListeningExecutorService pool = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(5));
    ListenableFuture<String> lf = pool.submit(new Task());
    System.out.println(lf.get());
    lf.addListener(() -> {
        System.out.println("finish lf");
    }, Executors.newFixedThreadPool(5));
}

Demo

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
public static void testListenFuture() {
    System.out.println("主任务执行完,开始异步执行副任务1.....");
    ListeningExecutorService pool = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(5));
    ListenableFuture<String> future = pool.submit(new Task());
    // 为任务绑定回调接口
    Futures.addCallback(future, new FutureCallback<String>() {
        @Override
        public void onSuccess(String result) {
            System.out.println("success,result->:" + result);
        }

        @Override
        public void onFailure(Throwable t) {
            System.out.println("error->" + t);
        }
    });
    System.out.println("副本任务启动,回归主任务线,主业务正常返回.....");
}

MoreExecutors：该类是 final 类型的工具类，提供了很多静态方法。

  • 使用 MoreExecutors.listeningDecorator(ExecutorService delegate) 方法初始化 ListeningExecutorService；

ListeningExecutorService：该类是对 ExecutorService 的扩展，重写 ExecutorService 类中的 submit 方法，返回 ListenableFuture 对象。

  • 使用 ListeningExecutorService 的 submit(Callable<T> var1) 方法即可初始化 ListenableFuture 对象。

Futures：该类提供和很多实用的静态方法以供使用。(todo: successfulAsList,AllAsList)

addCallback()：在线程结束时，立即调用 FutureCallBack()。

FutureCallback：该接口提供了 onSuccess() 和 onFailure()，获取异步计算的结果并回调，ListenableFuture 可以使用以下方式通过重写 onSuccess() 和 onFailure() 增加回调函数：

1
2
3
4
5
@GwtCompatible
public interface FutureCallback<V> {
    void onSuccess(@Nullable V var1);	// 当future执行成功，执行此方法
    void onFailure(Throwable var1);		// 当 future 执行失败，执行此方法
}

展开全文 >>

tag:

    缺失模块。
    1、请确保node版本大于6.2
    2、在博客根目录（注意不是yilia根目录）执行以下命令：
    npm i hexo-generator-json-content --save

    3、在根目录_config.yml里添加配置： 

      jsonContent:
    meta: false
    pages: false
    posts:
      title: true
      date: true
      path: true
      text: false
      raw: false
      content: false
      slug: false
      updated: false
      comments: false
      link: false
      permalink: false
      excerpt: false
      categories: false
      tags: true