AlbumenJ commented on issue #10188:
URL: https://github.com/apache/dubbo/issues/10188#issuecomment-1169445354
> > 1. 打断重试的这个需求应该是我们需要支持的，只是实现的方式需要考虑下
> > 2. 是否可以在 catch 异常的时候判断当前线程是否是已经被打断的，以此来确定是否需要把报错外发
>
> 写了一个简单的代码模拟下:
>
> ```java
> public static void main(String[] args) throws InterruptedException {
> ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(1,
1, 0, TimeUnit.SECONDS, new LinkedBlockingQueue<>());
>
> Future<?> submit = threadPoolExecutor.submit(() -> {
> System.out.println("before: " +
Thread.currentThread().isInterrupted());
> dubboInvoke();
> System.out.println("end: " +
Thread.currentThread().isInterrupted());
> });
> Thread.sleep(1000);
> submit.cancel(true);
> }
>
>
> static void dubboInvoke() {
> try {
> interruptError();
> } catch (Exception e) {
> //retry invoke
> }
> }
>
> static void interruptError() throws Exception {
> try {
> Thread.sleep(5000);
> System.out.println("wake up");
> } catch (Exception e) {
> //contains interrupt exception(RpcException)
> throw e;
> }
> }
> ```
>
> 控制台输出信息:
>
> ```java
> before: false
> end: false
> ```
>
> invoke产生的InterruptException没有被抛出, 外层通过
Thread.currentThread().isInterrupted() 方法是感知不到的
这里应该在 catch 异常的时候将线程的 isInterrupted 状态置上去，如果目前 Dubbo 没有做的话也需要完善下
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
