public class TestThreadUnsafe
{
    private final String[] array = new String[11];
    private int tail = 0;
   
    // 锁对象
    ReentrantLock lock = new ReentrantLock();

    public void offer(String e) throws InterruptedException
    {
        // 加锁 阻塞 时 可以随时被 打断
        lock.lockInterruptibly();
        try
        {
            // 需要受到 锁 保护的 代码块
            array[tail] = e;
            tail++;
        }
        finally
        {
            // 释放锁
            lock.unlock();
        }
    }

    @Override
    public String toString()
    {
        return Arrays.toString(array);
    }

    public static void main(String[] args)
    {
        TestThreadUnsafe queue = new TestThreadUnsafe();
        new Thread(() ->
        {
            try
            {
                queue.offer("e1");
            }
            catch (InterruptedException e)
            {
                throw new RuntimeException(e);
            }
        }, "t1").start();
        new Thread(() ->
        {
            try
            {
                queue.offer("e2");
            }
            catch (InterruptedException e)
            {
                throw new RuntimeException(e);
            }
        }, "t2").start();
    }
}