使用 Semaphore 运行时出现 java.util.NoSuchElementException

Question

我有一个包含 10 个元素的队列，我启动了 100 个线程，其中 6 个线程可以并发运行，由信号量控制。当每个线程运行时，它会获取头元素，然后将其添加到尾部。但有时我会遇到这个异常:

java.util.NoSuchElementException
 at java.util.LinkedList.removeFirst(LinkedList.java:270)
 at java.util.LinkedList.remove(LinkedList.java:685)
 at IBM.SemApp$1.run(SemApp.java:27)
 at java.lang.Thread.run(Thread.java:745)

import java.util.LinkedList;    
import java.util.Queue;
import java.util.Random;
import java.util.concurrent.Semaphore;

public class SemApp {
public static void main(String[] args) {

    Queue queueB = new LinkedList<>();
    for (int i = 0; i < 10; i++) {
        queueB.add("Object " + i);
    }

    Runnable limitedCall = new Runnable() {
        final Random rand = new Random();
        final Semaphore available = new Semaphore(6);
        int count = 0;

        public void run() {
            int time = rand.nextInt(15);

            try {
                available.acquire();
                String A = (String) queueB.remove();
                queueB.add(A);
                available.release();
                count++;
                System.out.println(count);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    };

    for (int i = 0; i < 100; i++) {
        new Thread(limitedCall).start();
    }
}
}

我做错了什么？

Answer 1

问题是 LinkedList 不是线程安全的结构。

因此，它不应该被多个并发线程共享和修改，因为 queueB 上的更改可能无法正确“传达”到其他线程。

尝试使用 LinkedBlockingQueue相反。

此外，出于同样的原因，使用 AtomicLong 进行 count :它在多个线程之间共享，并且您希望避免竞争条件。