j2ee_xx 2018-07-14 00:01 采纳率: 50%
浏览 3476
已结题

就是多线程处理list;以下代码如何能保证list安全呢

package com.gray.test;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;

public class ThreadTest {
public static void main(String[] args) throws Exception {
// 开始时间
long start = System.currentTimeMillis();
// 模拟数据List
List list = new ArrayList();
for (int i = 0; i < 3000; i++) {
list.add(i + "");
}

    ExecutorService exec = Executors.newFixedThreadPool(3);
     CountDownLatch doneSignal = new CountDownLatch(3);
    exec.execute(new PoiWriter(doneSignal,list,0,999));
    exec.execute(new PoiWriter(doneSignal,list,1000,1999));
    exec.execute(new PoiWriter(doneSignal,list,2000,2999));
    doneSignal.await();
    exec.shutdown();
    System.out.println("执行任务消耗了 :" + (System.currentTimeMillis() - start) + "毫秒");


}


protected static class PoiWriter implements Runnable {
    private  CountDownLatch doneSignal;
    private List list;
    private int start;

    private int end;

    public PoiWriter(CountDownLatch doneSignal,List list, int start, int end) {
        this.doneSignal = doneSignal;
        this.start = start;
        this.list = list;
        this.end = end;
    }

    @Override
    public void run() {
        try {
            for (int i = start; i <= end ;i++) {
                list.set(i, Thread.currentThread().getName() +"<--------->" + list.get(i));
                System.out.println(list.get(i));
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            doneSignal.countDown();
        }

    }
}

}

  • 写回答

7条回答 默认 最新

  • oyljerry 2018-07-14 00:10
    关注

    用synchronized包裹list操作的部分代码

    评论

报告相同问题?

悬赏问题

  • ¥15 求差集那个函数有问题,有无佬可以解决
  • ¥15 【提问】基于Invest的水源涵养
  • ¥20 微信网友居然可以通过vx号找到我绑的手机号
  • ¥15 寻一个支付宝扫码远程授权登录的软件助手app
  • ¥15 解riccati方程组
  • ¥15 display:none;样式在嵌套结构中的已设置了display样式的元素上不起作用?
  • ¥15 使用rabbitMQ 消息队列作为url源进行多线程爬取时,总有几个url没有处理的问题。
  • ¥15 Ubuntu在安装序列比对软件STAR时出现报错如何解决
  • ¥50 树莓派安卓APK系统签名
  • ¥65 汇编语言除法溢出问题