[Bug]: interrupt don't work

**AgentScope-Java is an open-source project. To involve a broader community, we recommend asking your questions in English.**

**Describe the bug**
InterruptionExample do not work

**To Reproduce**
run main method

/*
* Copyright 2024-2026 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package io.agentscope.examples.quickstart;

import io.agentscope.core.ReActAgent;
import io.agentscope.core.formatter.dashscope.DashScopeChatFormatter;
import io.agentscope.core.hook.ActingChunkEvent;
import io.agentscope.core.hook.ErrorEvent;
import io.agentscope.core.hook.Hook;
import io.agentscope.core.hook.HookEvent;
import io.agentscope.core.hook.PostActingEvent;
import io.agentscope.core.hook.PostCallEvent;
import io.agentscope.core.hook.PreActingEvent;
import io.agentscope.core.hook.PreCallEvent;
import io.agentscope.core.memory.InMemoryMemory;
import io.agentscope.core.message.ContentBlock;
import io.agentscope.core.message.Msg;
import io.agentscope.core.message.MsgRole;
import io.agentscope.core.message.TextBlock;
import io.agentscope.core.message.ToolResultBlock;
import io.agentscope.core.model.DashScopeChatModel;
import io.agentscope.core.tool.Tool;
import io.agentscope.core.tool.ToolEmitter;
import io.agentscope.core.tool.ToolParam;
import io.agentscope.core.tool.Toolkit;
import io.agentscope.examples.quickstart.util.MsgUtils;

import java.util.List;

import reactor.core.publisher.Mono;

import static io.agentscope.examples.quickstart.ModelConstants.CHAT_MODEL;

/**
* InterruptionExample - Demonstrates agent interruption mechanism.
*/
public class InterruptionExample {

public static void main(String[] args) throws Exception {
// Print welcome message
ExampleUtils.printWelcome("Interruption Example", "This example demonstrates user-initiated interruption of agent execution.\n" + "The agent will start a long-running task and be interrupted after 2" + " seconds.");
// Create toolkit with long-running tool
Toolkit toolkit = new Toolkit();
toolkit.registerTool(new LongRunningTools());

// Create agent with monitoring hook
ReActAgent agent = ReActAgent.builder().name("DataAgent").sysPrompt("You are a data processing assistant. " + "Use the process_large_dataset tool to process datasets.").model(CHAT_MODEL).toolkit(toolkit).memory(new InMemoryMemory()).maxIters(10).build();

// Create user message
Msg userMsg = Msg.builder().name("User").role(MsgRole.USER).content(TextBlock.builder().text("Please process the 'customer_data' dataset with" + " 'analyze' operation.").build()).build();
Thread agentThread = new Thread(() -> {
try {
agent.call(userMsg).block();
} catch (Exception e) {
System.err.println("[--------------------------------------------------------------] " + e.getMessage());
}
});

agentThread.start();
try {
System.out.println("cccccccccccccccccccc1");
Thread.sleep(5000);
agent.interrupt();
System.out.println("cccccccccccccccccccc2");
agentThread.join();
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
System.err.println("Main thread interrupted: " + e.getMessage());
}
}

public static class LongRunningTools {

@Tool(name = "process_large_dataset", description = "Process a large dataset (simulated long operation)")
public String processLargeDataset(@ToolParam(name = "dataset_name", description = "Name of the dataset") String datasetName, @ToolParam(name = "operation", description = "Operation to perform") String operation, ToolEmitter toolEmitter) {

System.out.println("[Tool] Starting to process dataset: " + datasetName + " with operation: " + operation);

// Simulate long-running operation with progress updates
for (int i = 1; i <= 10; i++) {
try {
System.out.println("---------------------------------------------do work" +"Processed " + (i * 10) + "%");
Thread.sleep(500); // 500ms per step = 5 seconds total
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
System.out.println("---------------------------------------------error");
return "Processing interrupted";
}

// Emit progress
toolEmitter.emit(ToolResultBlock.text("Processed " + (i * 10) + "%"));
}

return String.format("Successfully processed dataset '%s' with operation '%s'. " + "Results: 1000 records analyzed.", datasetName, operation);
}
}
}

io.agentscope
agentscope-dependencies-bom
${revision}
pom
import


io.agentscope
agentscope-bom
${revision}
pom
import

1.0.10

**Expected behavior**
=== Interruption Example ===

This example demonstrates user-initiated interruption of agent execution.
The agent will start a long-running task and be interrupted after 2 seconds.

[main] INFO io.agentscope.core.tool.Toolkit - Registered tool 'process_large_dataset' in group 'ungrouped'
cccccccccccccccccccc1
[Tool] Starting to process dataset: customer_data with operation: analyze
---------------------------------------------do workProcessed 10%
---------------------------------------------do workProcessed 20%
---------------------------------------------do workProcessed 30%
---------------------------------------------do workProcessed 40%
---------------------------------------------do workProcessed 50%
---------------------------------------------do workProcessed 60%
cccccccccccccccccccc2
---------------------------------------------do workProcessed 70%
---------------------------------------------do workProcessed 80%
---------------------------------------------do workProcessed 90%
---------------------------------------------do workProcessed 100%
[HttpTransportFactory-ShutdownHook] INFO io.agentscope.core.model.transport.HttpTransportFactory - Shutting down 1 managed HttpTransport(s)
Disconnected from the target VM, address: '127.0.0.1:10631', transport: 'socket'

**Error messages**
Detailed error messages.

**Environment (please complete the following information):**

version: 1.0.10
java version:17
windows
here.