java 如何实现一个同步锁 并且不阻塞的队列

要实现一个同步锁并且不阻塞的队列，可以使用Java的并发工具类来实现，比如使用ReentrantLock作为同步锁，使用Condition作为条件变量来实现队列的阻塞和唤醒操作。

下面是一个简单的示例代码：

import java.util.LinkedList;
import java.util.Queue;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.ReentrantLock;

public class NonBlockingQueue<T> {
    private Queue<T> queue;
    private ReentrantLock lock;
    private Condition notEmpty;

    public NonBlockingQueue() {
        queue = new LinkedList<>();
        lock = new ReentrantLock();
        notEmpty = lock.newCondition();
    }

    public void enqueue(T item) {
        lock.lock();
        try {
            queue.add(item);
            notEmpty.signal();
        } finally {
            lock.unlock();
        }
    }

    public T dequeue() throws InterruptedException {
        lock.lock();
        try {
            while (queue.isEmpty()) {
                notEmpty.await();
            }
            return queue.poll();
        } finally {
            lock.unlock();
        }
    }
}

在上述代码中，NonBlockingQueue类使用ReentrantLock作为同步锁，使用Condition的await()方法实现队列的阻塞操作，使用signal()方法实现队列的唤醒操作。

enqueue()方法用于向队列中添加元素，首先获取锁，然后将元素添加到队列中，最后使用signal()方法唤醒可能在等待的消费者线程。

dequeue()方法用于从队列中取出元素，首先获取锁，然后使用一个while循环判断队列是否为空，如果为空则调用await()方法阻塞当前线程，直到有元素被添加到队列中并调用signal()方法唤醒当前线程。当队列不为空时，使用poll()方法从队列中取出元素并返回。

需要注意的是，在使用Condition的await()方法时，需要将其放在一个循环中，以防止虚假唤醒（spurious wakeup）的情况发生。