在Java中向线程池中添加新任务之前等待任务完成的最佳方法？

3 回答

• 1

  我毫不怀疑那些对这部分API有更多经验的人会有更好的想法，但这是我对这个主题的看法......

  基本上，我'd start with a 2639163 and 2639164 queue. The 2639165 queue keeps track of what'当前正在运行，"waiting"队列会跟踪您阻止的任务 . 这些队列需要键入某种"group identifier"以便于查找（例如 Map<String, List<Runnable> ），例如，您的帐号

  我会看一下覆盖 execute 方法 . 在这里，我将新任务放入等待队列 .

  然后我会覆盖 beforeExecute 方法 . 在这里，我将在"running"队列中注册任务 .

  我'd override the ' afterExecute'方法 . 在这里，我将从"running"队列中删除已完成的任务，查找等待任务的队列（通过已完成任务的组标识符），并通过 execute 方法将队列中的第一个任务添加到执行程序中

  或者你可以像路易斯建议的那样做：P

  回复于 2024-04-26T11:27:33+08:00
• 1

  一个简单的可能性也许过于简单 . 创建10个SingleThreadedExecutors . 对于每项任务

  • "hash" accountID采用accountID mod 10来查找相应的SingleThreadedExecutor . （实际上，accountID可能不是int，例如，如果它是＃2639178_ s hashCode（）mod 10） .

  • 将任务提交给SingleThreadedExecutor .

  这可能并不理想，因为帐户238的处理将被迫等到358完成，但至少您确定某个特定帐户（例如234）将永远不会同时运行 . 取决于您可以允许的延迟时间 . 显然，你可以使用Executors的数量和我所描述的简单化的“散列”algortihm .

  回复于 2024-04-26T11:27:33+08:00
• 1

  我遇到了同样的问题 . 我的解决方案是使用HashSet .

  private static HashSet<Integer> runningTasks = new HashSet();
  
  public void run(){
    boolean isAlreadyRunning = false;
    synchronized (runningTasks) {
      if (runningTasks.contains(this.accountId)) {
        isAlreadyRunning = true;
      } else {
        runningTasks.add(this.accountId);
      }
    }
    if(isAlreadyRunning){
      //schedule this task to run later here
      //what I did was to reinsert this task to the task queue 5 seconds later
      return;
    }
    //do your stuffs here
  
    synchronized (runningTasks) {
      runningTasks.remove(this.accountId);
    }
  }
  

  回复于 2024-04-26T11:27:33+08:00