为什么Handler中可以使用异步而Filter中不行了？

[xhanthow]

我在Handler中使用了CompletableFuture，代码如下：

public void handle(Invocation invocation, AsyncResponse asyncResp) throws Exception {
	SomeTask task = new SomeTask(completableFuture);
	ThreadPoolUtil.getInstance().execute(task);
	completableFuture.whenComplete((res, ex) -> {
		try {
			afterCheckRights(res, asyncResp, invocation);
		} catch (Throwable e) {
			asyncResp.consumerFail(new InvocationException(Status.BAD_GATEWAY, e.getMessage()));
		}
	});
}

private void afterCheckRights(String res, AsyncResponse asyncResp, Invocation invocation) throws Exception {
	// 发现这里切换了线程，之前是eventloop的，现在是自己定义的线程池，这样有什么影响吗？
}

[liubao68]

看你的描述像是代码本身执行逻辑导致的问题， 即 completableFuture.complete在哪个线程被调用了。

"Filter中不行" 没看到描述， 不是很清楚这个表达代表的意思。

[xhanthow]

completableFuture.complete在是在我自己定义的线程池中执行的，我就想问下这个会影响效率么？因为开始都是在eventloop中执行的，然后切换到了自己的线程中。
"Filter"中不行和这个issue描述差不多：#1324

[wujimin]

基本上我认为这是一个设计缺陷
当初定义HttpServerFilter时，仅仅为了用于干预一下codec逻辑而已
相关的缺陷，在这里也有一定的描述：https://issues.apache.org/jira/browse/SCB-1929

使用新的Filter机制，可以解决reactive认证/鉴权的问题
不过Filter机制还没有正式发布，我在自己的项目里正在试用

线程变换的问题，从能不能跑的角度看，应该是没问题，但是能不能跑得好，这个需要你来评估
比如，所有请求都要走认证/鉴权，所有的请求就都跑到你这个线程池里去了，是否顶得住？

另外：CompletableFuture使用指定线程池执行，可以使用它的带async后缀的方法，并指定你想要的executor即可，代码会清晰不少

[xhanthow]

也就是说这样就不会影响eventloop线程了吧。
新的Filter机制有设计文档么（是否和Handler设计类似了？），想对着https://issues.apache.org/jira/browse/SCB-1929学习学习。

[wujimin]

是的，不会影响eventloop
还没有文档，只有那个issue，相应的代码，可以看那issue的subTask对应的PR，点进去都有链接

[xhanthow]

嗯，把代码下下来看了下，这里就启动了Filter链（感觉和之前的Handler有点像，invocation.next(xxx)）

  public CompletableFuture<Response> onFilter(Invocation invocation) {
    if (!filter.enabled()) {
      return nextNode.onFilter(invocation);
    }
    
    return AsyncUtils.tryCatch(() -> filter.onFilter(invocation, nextNode))
        .thenApply(this::rethrowExceptionInResponse);
  }

而且现在Filter可以使用Autowire了吧 :)

engine.getApplicationContext().getAutowireCapableBeanFactory().autowireBean(filter)

不过我现在还有个疑问，就是我在Handler中用了异步（如issue中第一个描述中的代码），自己定义的线程池，然后我debug的时候发现后续的Invocation#next执行的时候也都在我自定义的线程池中执行，后续的操作还有可能切换到eventloop线程中执行么？

[wujimin]

是的，新的Filter机制是将旧的各种扩展点全部归一化了，要实现的功能还是一样的
Filter的成员确实允许Autowire了
要切回eventloop，可以：

  VertxTransportContext transportContext = invocation.getTransportContext();
  Executor executor = VertxContextExecutor.create(transportContext.getVertxContext());
  future.xxxAsync(xxx, executor)
    .xxxxxx

xxx就在eventloop中执行了

要注意，future有个“特点”，下面用例中第二个apply不一定会在executor中执行，结果是由本线程与executor的真实执行顺序决定的，而这个顺序本身就是不确定的：

    @Test
    @Disabled("用于证明jdk的CompletableFuture确实有问题，有较高概率出现，但是也不是必现；为防止CI概率性失败，改为手工执行")
    void completable_future_thread_is_not_stable() {
        for (int idx = 0; idx < LOOP_COUNT; idx++) {
            CompletableFuture.completedFuture(null)
                .thenApplyAsync(this::apply, executor)
                .thenApply(this::apply)
                .join();
        }

        assertThat(threadNames).containsExactlyInAnyOrder("main", UT_THREAD_NAME);
    }

[xhanthow]

这个类VertxContextExecutor在1.2.0中是没有的吧，我看最新代码中是有的。
学习了~
刚又debug了下，由于我的Handler是第一个，所以剩下的几个（除了最后一个Handler：TransportClientHandler）都是在我自己定义线程池中执行的。直到最后一个Handler执行这个动作就会发生线程切换吧：

这个动作和VertxContextExecutor这个类逻辑差不多

[wujimin]

1.x系列早就是维护状态了，新特性都在2.x中，Filter估计在3.x中发布
VertxContextExecutor实际就是对runOnContext的包装，为了方便与CompletableFuture配合使用

[xhanthow]

好的，了解了。谢谢~