可调用接口 循环停止主方法以进一步执行

Question

我正在尝试在线程中每 2 秒向服务器发送请求，并检查是否有适合我的东西将其还给我......为了获得价值，我必须使用可调用的。我无法弄清楚如何在每 2 秒内运行可调用线程并从中获取价值......这是我的可调用实现的示例代码...

public String call(){
    boolean done = true;
    String returnData = "";
    while(done){
        try {
            returnData = post.getAvailableChat();
            if(!returnData.equals("")){
                System.out.println("Value return by server is "+returnData);
                return returnData;
            }
            return null;
        } catch (IOException ex) {
            done = false;
            Logger.getLogger(GetChatThread.class.getName()).log(Level.SEVERE, null, ex);
        }

现在这是我的主类代码，我知道我在主类中做错了，因为我的代码在 while 循环后不会转到下一行......但请告诉我该怎么做

Callable<String> callable = new CallableImpl(2);                  
    ExecutorService executor = new ScheduledThreadPoolExecutor(1);   
    System.err.println("before future executor");                    
    Future<String> future;                                           
    try {                                                           
        while(chatLoop_veriable){                                    
            future = executor.submit(callable);                         
            String serverReply = future.get();                      
            if( serverReply != null){                               
                System.out.println("value returned by the server is "+serverReply);
                Thread.sleep(2*1000);                               
            }//End of if                                            
        }//End of loop                                              
    } catch (Exception e) {                                         

Answer 1

你正确地选择了 ScheduledThreadPoolExecutor，但你没有利用它提供的方法，特别是在你的情况下：scheduleAtFixedRate 而不是提交。然后，您可以删除睡眠部分，因为执行程序将为您处理计划。

Answer 2

Future.get()阻塞，因此在线程完成之前，控制权不会返回给您。 你应该使用 Future.get（长超时，时间单位）

future.get(2, TimeUnit.SECONDS);

Answer 3

我认为它应该更像 API 文档中的这个（请注意，没有"public"修饰符，因此可能需要是嵌套子类或类似的东西来解决变量的访问级别）它应该是这样的.....

Callable<String> call(){
 // code for the 2000 millisecond thread Callable is some sort of data/process for 
 // a thread to "do"
 return (Callable<String>)callable; // or 1
}

然而，java.util.concurrent.Executors似乎是用Callable实现这一点的方式。注意 V 是 API 文档中的向量。