From 4ff894095c4a7fe14df390a8a75b1ad81c58129b Mon Sep 17 00:00:00 2001
From: Pedja <predrag4@gmail.com>
Date: Fri, 27 Jan 2017 11:52:17 +0100
Subject: [PATCH] BAEL-614 Added "public" to class definitions; Formatted code

---
 .../concurrent/blockingqueue/BlockingQueueUsage.java        | 2 --
 .../baeldung/concurrent/blockingqueue/NumbersConsumer.java  | 4 +---
 .../baeldung/concurrent/blockingqueue/NumbersProducer.java  | 6 +-----
 3 files changed, 2 insertions(+), 10 deletions(-)

diff --git a/core-java/src/main/java/com/baeldung/concurrent/blockingqueue/BlockingQueueUsage.java b/core-java/src/main/java/com/baeldung/concurrent/blockingqueue/BlockingQueueUsage.java
index 63c6cc4460..801dc4e35c 100644
--- a/core-java/src/main/java/com/baeldung/concurrent/blockingqueue/BlockingQueueUsage.java
+++ b/core-java/src/main/java/com/baeldung/concurrent/blockingqueue/BlockingQueueUsage.java
@@ -1,6 +1,5 @@
 package com.baeldung.concurrent.blockingqueue;
 
-
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.LinkedBlockingQueue;
 
@@ -10,7 +9,6 @@ public class BlockingQueueUsage {
         int N_PRODUCERS = 4;
         int N_CONSUMERS = Runtime.getRuntime().availableProcessors();
 
-
         BlockingQueue<Integer> queue = new LinkedBlockingQueue<>(BOUND);
 
         for (int i = 0; i < N_PRODUCERS; i++) {
diff --git a/core-java/src/main/java/com/baeldung/concurrent/blockingqueue/NumbersConsumer.java b/core-java/src/main/java/com/baeldung/concurrent/blockingqueue/NumbersConsumer.java
index 110a801acc..774c263a3b 100644
--- a/core-java/src/main/java/com/baeldung/concurrent/blockingqueue/NumbersConsumer.java
+++ b/core-java/src/main/java/com/baeldung/concurrent/blockingqueue/NumbersConsumer.java
@@ -1,9 +1,8 @@
 package com.baeldung.concurrent.blockingqueue;
 
-
 import java.util.concurrent.BlockingQueue;
 
-class NumbersConsumer implements Runnable {
+public class NumbersConsumer implements Runnable {
     private final BlockingQueue<Integer> queue;
 
     public NumbersConsumer(BlockingQueue<Integer> queue) {
@@ -16,7 +15,6 @@ class NumbersConsumer implements Runnable {
                 Integer number = queue.take();
                 String result = number.toString();
                 System.out.println(Thread.currentThread().getName() + " result: " + result);
-
             }
         } catch (InterruptedException e) {
             Thread.currentThread().interrupt();
diff --git a/core-java/src/main/java/com/baeldung/concurrent/blockingqueue/NumbersProducer.java b/core-java/src/main/java/com/baeldung/concurrent/blockingqueue/NumbersProducer.java
index c9e91cd077..dcc0b48453 100644
--- a/core-java/src/main/java/com/baeldung/concurrent/blockingqueue/NumbersProducer.java
+++ b/core-java/src/main/java/com/baeldung/concurrent/blockingqueue/NumbersProducer.java
@@ -1,20 +1,16 @@
 package com.baeldung.concurrent.blockingqueue;
 
-
 import java.util.Random;
 import java.util.concurrent.BlockingQueue;
 
-
-class NumbersProducer implements Runnable {
+public class NumbersProducer implements Runnable {
     private final Random random = new Random();
     private final BlockingQueue<Integer> numbersQueue;
 
-
     public NumbersProducer(BlockingQueue<Integer> numbersQueue) {
         this.numbersQueue = numbersQueue;
     }
 
-
     public void run() {
         try {
             generateNumbers();