@Test
public void testIsEmpty002() throws Exception {

    int capacity = 1;
    final ArrayBlockingQueueEx<DataValueObject> queue = new ArrayBlockingQueueEx<DataValueObject>(capacity);
    Thread thread01 = new Thread() {
        @Override
        public void run() {
            try {
                sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            DataValueObject obj1 = new DataValueObject("hoge");
            queue.add(obj1);
        }
    };
    thread01.start();
    // 別スレッドでキューイング終了通知を行うとtrueを返す
    assertFalse(queue.isEmpty());
}