java – 在CompletableFuture中多次运行Runnable

发布时间：2020-12-15 08:27:05 所属栏目：Java 来源：网络整理

导读：我想执行多个线程,它们会尝试同时添加到我的自定义列表MyList中,但是当我尝试计数时我看不到任何输出 public static void main(String[] args) { MyListString list = new listString(); MyRunnerString myRunner = new MyRunnerString(list); ExecutorServi

我想执行多个线程,它们会尝试同时添加到我的自定义列表MyList中,但是当我尝试计数时我看不到任何输出

public static void main(String[] args) {

        MyList<String> list = new list<String>();

        MyRunner<String> myRunner = new MyRunner<String>(list);

        ExecutorService threadPool = Executors.newFixedThreadPool(4);

        for(int i = 0; i < 20; i++) {
            CompletableFuture.runAsync(new MyRunner<String>(list));
        }

        try {
            threadPool.awaitTermination(100l,TimeUnit.SECONDS);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        System.out.println(list.getCount());
}

跑步者班：

class MyRunner<String> implements Runnable {

    MyList<String> list;

    public MyRunner(MyList <String> t) {
        this.list = t;
    }

    @Override
    public void run() {
        for(int i = 0; i < 200; i++) {
            list((String) (i + Thread.currentThread().getName()));
        }

    }
}

class MyList：

public class MyList<T> {

    Queue<T> blockingQueue;
    Lock lock;

    long count;

    public MyList() {
        blockingQueue = new LinkedList<>();
        count = 0;
        lock = new ReentrantLock();
    }

    public void add(T singleTon) {
        lock.lock();
        blockingQueue.offer(singleTon);
        count +=1;
        lock.unlock();
    }

    public long getCount() {
        return count;
    }


}

跟进问题：

使用CountDownLatch程序没有结束. sysout的数量是10001,最后一个输出是在runnable：9：pool-1-thread-1

CountDownLatch实现：

public static void main(String[] args) throws InterruptedException {

        MyList<String> mylist = new MyList<>();

        CountDownLatch latch = new CountDownLatch(10);

        ExecutorService executorService = Executors.newFixedThreadPool(4);


        for(int i = 0; i < 1000; i++) {
            CompletableFuture.runAsync(new MyRunner<String>(mylist,latch),executorService);
        }

        latch.await();

        System.out.println(mylist.count);
    }


class MyRunner<String> implements Runnable {

    MyList<String> mylist;
    CountDownLatch latch;

    public MyRunner(MyList<String> mylist,CountDownLatch latch) {
       this.latch = latch;
       this.mylist = mylist;
    }

    @Override
    public void run() {
        for(int i = 0; i < 10; i++) {
            System.out.println("In runnable: "+ i + " : "+ Thread.currentThread().getName());
            mylist.add((String)("" + i));
        }

        latch.countDown();
    }
}

解决方法

您调用不使用您创建的执行程序的CompletableFuture.runAsync(Runnable runnable).
通过传递Executor实例来代替CompletableFuture.runAsync(Runnable runnable,Executor executor),例如：

CompletableFuture.runAsync(new MyRunner<String>(list),threadPool);

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!