--- Java

import java.util.concurrent.ArrayBlockingQueue;

class Main {
  public static void main(String[] args) throws InterruptedException {
    ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<>(5);
    for (;;) {
      String msg = queue.take();
      System.out.println(msg);
    }
  }
}

--- Bytecode

public static void main(java.lang.String[]) throws java.lang.InterruptedException;
    descriptor: ([Ljava/lang/String;)V
    flags: ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=3, args_size=1
         0: new           #2                  // class java/util/concurrent/ArrayBlockingQueue
         3: dup
         4: iconst_5
         5: invokespecial #3                  // Method java/util/concurrent/ArrayBlockingQueue."<init>":(I)V
         8: astore_1
         9: aload_1
        10: invokevirtual #4                  // Method java/util/concurrent/ArrayBlockingQueue.take:()Ljava/lang/Object;
        13: checkcast     #5                  // class java/lang/String
        16: astore_2
        17: getstatic     #6                  // Field java/lang/System.out:Ljava/io/PrintStream;
        20: aload_2
        21: invokevirtual #7                  // Method java/io/PrintStream.println:(Ljava/lang/String;)V
        24: goto          9