为什么只有 5 个线程中的一个从堆栈中弹出元素？

Question

public class ClassTest extends Thread{

    public static Object lock = new Object();
    
    public static LinkedList<Integer> stack;
    public SortedSet<Integer> set= new TreeSet<>();
    @Override
        public void run(){
            
            synchronized(lock){
                // try{
                    // this.wait();
                // }
                // catch(Exception e){
                    // e.printStackTrace();
                // }
                
                
                while(!stack.isEmpty()){
                    set.add(stack.pop());
                    
                    this.yield();
                    
                    // this.notifyAll();
                    
                }
                
                
            }
            
            
        }

当我启动（）5 个线程时，为什么只有第一个弹出所有元素而其他的不弹出任何元素？我尝试使用 wait() 和 notify() 方法，但这没有帮助..

Answer 1

方法yield不释放锁。第一个进入同步块的线程将阻止其他线程进入，直到堆栈为空并释放锁。

这是一个使用 LinkedBlockingDeque.

执行您想要的操作的示例

import java.util.HashSet;
import java.util.Set;
import java.util.concurrent.LinkedBlockingDeque;


class Main {
    
    static final LinkedBlockingDeque<Integer> stack = new LinkedBlockingDeque<>();
    
    
    static class Poller implements Runnable {
        final Set<Integer> set = new HashSet<>();
        
        @Override
        public void run() {
            Integer elem = stack.poll();
            while (elem != null) {
                set.add(elem);
                System.out.printf("%s: %d\n", Thread.currentThread().getName(), elem);
                elem = stack.poll();
            }
        }
    }
    
    
    public static void main(String args[]) {
        for (int i = 0; i < 100; i++) {
            stack.push(i);
        }
        for (int i = 0; i < 5; i++) {
            new Thread(new Poller()).start();
        }
    }
}

为什么只有 5 个线程中的一个从堆栈中弹出元素？

Why just one of 5 threads pop elements from stack?

java

multithreading

synchronization

thread-safety