是否可以获得正在运行的线程的引用？

Question

这是我在社区的第一篇文章。欢迎任何cmets和建议。 我在端点http://ip:port/report 上有一个网络服务。该服务执行一个 Runnable 类。执行 Runnable 后，是否可以通过单独的服务调用来检查/监视线程？

我仍在工作并寻找 ExecutorService 之类的东西，但仍然没有运气。有没有其他方法可以做到这一点？请提出一些我可以检查的可能的解决方案。对不起我的语法。我希望我能用下面的示例代码解释清楚。

我的代码是这样的。

在http://ip:port/report上运行线程

public String runReport {

    // Run the the runnable
    Report report = new Report();
    String threadName = "REPORT1";
    Thread t = new Thread(report, threadName);
    t.start();

    // return thread some details
    return t.getId() + "|" + t.hashCode();
}

我的可运行类

public class Report {

    private String status;

    @Override
    public void run() {
        //Update status
        setStatus("Running");

        //... do stuff

        //Update status
        setStatus("End")
    }

    // Getter and Setter
}

我在http://ip:port/report/check/some_param上的跳棋课

public String check( int threadId ) {
    // Search the thread by threadId and check the current status
    //Report.getStatus();
}

Answer 1

使用线程 ID 可能不是最好的主意，尤其是因为您可能会使用可重用线程的池。 一个简单的解决方案是为您的作业生成 ID 并维护一个可用于读取状态的地图。

例如，您可以为任务 ID 使用唯一 ID：

Map<String, Report> jobs = new ConcurrentHashMap<>();
ExecutorService executorService = Executors.newFixedThreadPool(10); //just an example

public String runReport {

    // Run the the runnable
    Report report = new Report();

    //For a numeric sequence, you can use something like AtomicLong
    String jobId = UUID.randomUUID().toString();
    jobs.put(jobId, report);

    //using a thread pool may be a better idea.
    executorService.submit(report);

    // return the job ID
    return jobId;
}

要检查状态，您只需阅读地图：

public String check(String jobId) {
    return jobs.get(jobId).getStatus(); //remember null checks
}

然后，您只需要根据您期望调用 check 方法的方式知道何时从映射中删除条目。

Answer 2

在您的工作 ID 的类中维护地图。 每当该线程被初始化时，在构造函数中传递 id，当它开始处理时将状态设置为正在运行，当它完成时，在 run 方法中结束执行之前，将状态设置为结束。如下所示

public void run(){
     try{
     jobsMap.put(this.jobId, "Running");
     // your business logic here
     jobsMap.put(this.jobId,"Completed");
     } catch(Exception e){
       jobsMap.put(this.jobId,"Failed. Reason -"+e.getMessage);
       // exception handling
     }
}