Concurrency exmple with N consumers

Main.java

package com.company;

import java.util.ArrayList;
import java.util.List;
import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.atomic.AtomicInteger;

public class Main {

    public static void main(String[] args) throws InterruptedException {
        // write your code here
        Queue<Integer> numbersQueue = new ConcurrentLinkedQueue<>();
        List<NumbersThread> threads = new ArrayList<>();
        AtomicInteger consumed = new AtomicInteger();
        consumed.set(0);
        for (int i = 0; i < 5; i++) {
            threads.add(new NumbersThread(numbersQueue, consumed));
        }
        for (NumbersThread thread : threads) {
            thread.start();
        }
        for (int i = 0; i < 1000; i++) {
            numbersQueue.offer(i);
        }
    }
}

public class NumbersThread  extends Thread {
    private AtomicInteger consumed;
    private boolean stopped = false;
    private Queue<Integer> queue;
    private static Integer MAX_CONSUMED = 1000;

    NumbersThread (Queue newQueue, AtomicInteger globalConsumed) {
        queue = newQueue;
        consumed = globalConsumed;
    }

    public void run () {
        while (!stopped && consumed.get() < MAX_CONSUMED) {
            Integer newValue = queue.poll();
            if (null != newValue) {
                consumed.getAndAdd(1);
                System.out.println("Processed " + newValue);
            }
        }
    }
}