java - 如何在 Android 中由 ScheduledExecutorService 生成的两个线程之间传递数据？

Question

我正在尝试通过 ScheduledExecutorService 在 Android 中实现生产者-消费者模式。因此，我创建了一个从网站加载数据的生产者工作线程和过滤此数据的消费者线程。这是演示我的问题的代码 fragment :

public void RunPeriodicBackgroundTasks() {
  private final ScheduledExecutorService backgroundTaskExecutor_ = Executors.newScheduledThreadPool(2);
backgroundTaskExecutor_.scheduleAtFixedRate(new Runnable() {
    @Override
    public void run() {
   LinkedHashMap<String, Object> result_ = new LinkedHashMap<String, Object>(lowLevelNetworkOperation_.executeServerCommand(DASHBOARD_INBOX_SENT_COMMAND, params)); 
    }
},1 ,3, SECONDS);
    //AND NOW I CREATE ANOTHER THREAD for the second task
   backgroundTaskExecutor_.scheduleAtFixedRate(new Runnable() {

    @Override
    public void run() {
        //HERE I WANT To USE result_

    }
}, 1,3, SECONDS);
    }

Answer 1

您可以在此处使用 ConcurrentLinkedQueue。

在您的第一个 run 方法中。

private final ConcurrentLinkedQueue<Map.Entry<String,Object>> queue = new ConcurrentLinkedQueue<Map.Entry<String,Object>>();
public void run(){
   LinkedHashMap<String, Object> result_ = new LinkedHashMap<String, Object>(lowLevelNetworkOperation_.executeServerCommand(DASHBOARD_INBOX_SENT_COMMAND, params)); 

   for(Map.Entry<String,Object> entry: result_.entrySet()){
      queue.offer(entry);
   }
}

在你的另一场比赛中

public void run(){
   List<Map.Entry> currentEntries = new ArrayList<Map.Entry>();
   Map.Entry  entry = null;
   while((entry = queue.poll())!=null){
       currentEntries.add(entry);
   }
   //use it now
}

现在您会注意到这违反了生产者/消费者模式，因为您的两个线程是按固定速率调度的。这意味着它会周期性地一次又一次地唤醒/运行/ sleep 。 ConcurrentLinkedQueue 不会阻塞，因此如果队列中没有元素，它将返回 null。

如果您希望它成为真正的生产者/消费者，您应该按原样安排第一个任务，但第二个任务将等待队列信号唤醒。

final BlockingQueue<Map.Entry>queue = new LinkedBlockingQueue<Map.Entry>();

//This is your second run
public void run(){
    while(!Thread.currentThread().isInterrupted()){
        Map.Entry current = queue.take(); //suspend here if the queue is empty until it 1 or more elements
        //use current
    }
}