java - 如何 promise 完成多个线程？

Question

我对 java 中的多线程概念有点陌生。
这个问题的标题可能与之前关于该主题的问题有相似之处，但尽管查看了答案，我仍然成功地完成了以下任务:

在 MainActivity 上说我有一个嵌套的 for 循环。在内部循环中，我正在运行另一个类的方法，该方法将接口(interface)作为回调，如下所示:

MainActivity.java

public View onCreateView(LayoutInflater inflater, ViewGroup container,
                         Bundle savedInstanceState) {
    View v = inflater.inflate(R.layout.fragment_display_prices, container, false);

    return v;

    for (i = 0; i < 10; i++) {

        for (i = 0; i < 4; i++){
              CategoryItemsDataSource.getCategoryItemsData(url, new CategoryItemsDataSource.OnCategoryItemsDataArrived() {
                        @Override
                        public void onCategoryItemsDataArrived(List<ProductItem> data, Exception e) {
                             getActivity.runOnUiThread(new Runnable() {

                                   //display retrieved data on UIThread...
                             });

                        }
              });
        }
    }

}

CategoryItemDataSource.java

 public class CategoryItemsDataSource {

public interface OnCategoryItemsDataArrived {
    void onCategoryItemsDataArrived(List<ProductItem> data, Exception e);
}

public static void getCategoryItemsData(final String[] url, final OnCategoryItemsDataArrived listener){

    ExecutorService service = Executors.newSingleThreadExecutor();
    service.execute(new Runnable() {
        @Override
        public void run() {
            try {
                List<ProductItem> data = new ArrayList<>();
                //retreiving data from web and appending to List<> Data....
                }
                listener.onCategoryItemsDataArrived(data, null);
            } catch (Exception e) {
                e.printStackTrace();
                listener.onCategoryItemsDataArrived(null, e);
            }
        }
    });
    service.shutdown();
}

我不知道如何从 MainActivity 中的 CategoryItemDataSource 类 [I.E，如果我需要的话] 访问 ExecutorService 实例。因此，我应该如何确保/ promise 完成内部循环中生成的所有多个线程？

Answer 1

创建一个计数器变量；在循环中，每次将新任务提交给执行程序时递增计数器。在 onCategoryItemsDataArrived 方法中，递减该计数器；当它变为零时，所有任务都已完成。提供对计数器的原子访问:使用 AtomicInteger 或 synchronized 语句。