Question

java大数据 多线程写文件

目前有7000万条数据要写入txt文件，我是分为多个线程，暂定为7个吧，每个线程都会将1000万条数据写入临时txt文件中，最后再通过nio的一个工具类合并，目前存在的问题是，进度的更新问题，目前是采取子线程每写入10万条数据然后更新数据库中进度这个字段。等于说进度是子线程写的，目前我想用主线程写进度，但是我用的这个类实现唤醒主线程CountDwonLatch，所以只有所有子线程结束，主线程才会醒过来，现在我想主线程定期的醒过来去写进度，哎，如果CountDwonLatch这个类支持回调函数就好了

Answer 1

1、采用public static的变量存储这一数值，每个线程都往这一共有静态变量里写入已复制大小。 2、采用Callable方式实现多线程，将结果作为返回值返回到主线程。这一方法只能在所有子线程都完成之后才能通过future获取。