Android 线程 - 延迟重复线程组几次

Question

我将实现一个从 Android 设备收集数据的应用程序。

这是我现在所拥有的：

• 带有按钮的主要活动运行
• 按钮启动记录器
• 记录器有4个资源 可运行
  • Gps资源
  • 图像资源
  • 音频资源
  • 陀螺仪资源
• 在Recorder中，有一个for循环（例如i <3），它运行线程包一些延迟 (i * 5000)

我应该如何创建该线程，以便所有线程同时启动 (i=0)，然后在 5 秒后再次启动 (i=1) 并在接下来的 5 秒后再次 (i=2) ？

接下来的事情：

每个资源都使用 getData() 方法返回一些数据 - 简化它 - 带有随机字符的字符串。如何在Recorder中通知队列中的所有线程都已完成并从资源中收集所有数据？

最后一件事：

我必须能够在创建所有队列后停止执行所有线程。示例：

我们有第 7 秒，第二个队列正在运行，用户单击按钮停止。正在运行的线程的队列即将完成，但下一个队列将不会启动，只是 Recodred 必须忘记它们。

我尽量写得简单一些，相信你们能理解我的意思。

感谢您的任何建议！

Answer 1

这里有一个想法可以解决至少一部分问题：

一起启动资源并等待它们完成：

采用 CompletionService：

Executor e = Executors.newFixedThreadPool(4);
CompletionService<String> service = new ExecutorCompletionService<String>(e);
CountDownLatch startLatch = new CountDownLatch(1);
for (int i=0; i<numberOfResources; i++) {
     Resource r = createResource(startLatch, i);
     service.submit(r);
}
startLatch.countDown();

Resource 应该如下所示：

class Resource implements Callable<String> { 
    private final CountDownLatch latch;
    public Resource(CountDownLatch latch) { this.latch = latch; }
    public String call() throws Exception {
        latch.await();
        return getData();
    }
}

不从完成服务中获取数据：

for (int i=0; i<numberOfResources; i++) {
    String data = service.take().get();
    // do something with data
}

请注意，这更多是伪代码，未经过实际测试:)

并且仍然存在悬而未决的问题，如果某些资源执行时间超过 5 秒，您会做什么。另一种是每 5 秒安排一次相同的操作。