NullPointerException이

Question

가능한 중복 :
I am getting NullPointerException inside Consumer

이 프로듀서의 버그로 간주되어, 소비자 시나리오?

이것은 제작자 클래스입니다.

package com ; 

import java.util.concurrent.PriorityBlockingQueue; 

public class Producer extends CommonClass implements Runnable { 
    private SyncronizedStack stack; 
    private int producerNum; 

    Producer(PriorityBlockingQueue<Character> queue) { 
     this.queue = queue; 
    } 

    public void run() { 

     char ch; 

     for (ch = 'a'; ch <= 'f'; ch++) { 
      queue.add(ch); 
      System.out.println("Producer" + producerNum + "produced :" + ch); 
      try { 
       Thread.sleep((int) (Math.random() * 300)); 

      } catch (InterruptedException e) { 
       System.out.println("Error"); 
      } 

     } 

    } 

} 

이 내 소비자 클래스입니다

package com ; 

import java.util.concurrent.PriorityBlockingQueue; 

public class Consumer extends CommonClass implements Runnable { 

    private int consumerNum; 

    Consumer(PriorityBlockingQueue<Character> queue) { 
     this.queue = queue; 
    } 

    public void run() { 
     char c; 
     for (int i = 0; i < 7; i++) { 
      try { 
       c = queue.take(); 
       System.out.println("Consumer" + consumerNum + "consumed:" + c); 
      } catch (Exception e1) { 
       e1.printStackTrace(); 
      } 
      try { 
       Thread.sleep((int) (Math.random() * 300)); 
      } catch (InterruptedException e) { 
       System.out.println("Error"); 
      } 
     } 

    } 
} 

이이 내 클라이언트 프로그램입니다

package com ; 

import java.util.concurrent.PriorityBlockingQueue; 

public class CommonClass { 

    PriorityBlockingQueue<Character> queue = null; 

} 

내 CommonClass입니다

난이 실행할 때 451,515,

package com ; 

import java.util.concurrent.PriorityBlockingQueue; 

public class SyncTest { 

    public static void main(String[] args) { 

     CommonClass cs = new CommonClass(); 

     PriorityBlockingQueue<Character> queue = new PriorityBlockingQueue<Character>(); 

     Producer p1 = new Producer(queue); 
     Thread t1 = new Thread(p1); 
     t1.start(); 

     Consumer c1 = new Consumer(queue); 
     Thread ct1 = new Thread(c1); 

     ct1.start(); 

    } 
} 

는 난이 E 및 F 알파벳의 경우에 출력

Producer0produced :a 
Consumer0consumed:a 

Producer0produced :b 
Consumer0consumed:b 

Producer0produced :c 
Consumer0consumed:c 

Producer0produced :d 
Consumer0consumed:d 

Producer0produced :e 
Producer0produced :f 
Consumer0consumed:e 
Consumer0consumed:f 

으로 얻는다.

이 출력에 문제가 있습니까 ?? 나는 Producer0produced 문장을 동시에 두 번 보았고 Consumer0consumed 문 다음에 e와 f라는 문자를 동시에 출력했다.

이 코드를 사용하면 제작자가 제작 한 정보가 누락 될 수 있습니다.

제발 조언 ??

감사합니다.

Answer 1

이 출력에 문제가 있습니까?

아니요. 생산자 스레드는 소비자가 첫 번째 항목을 소비하기 전에 두 번째 항목을 생성하기 만했습니다. 그것은 전적으로 자연 스럽습니다. 특히 당신이 임의의 시간 동안 자고있을 때.

물론 큐의 상한값을 지정하고 add 대신 offer을 사용하여 큐가 가득 찼던 상황을 감지 할 수 있지만 표시 한 결과는 문제가 없습니다.

Answer 2

나는 Producer0produced 문장을 동시에 두 번 본 다음 Consumer0consumed 문을 e와 f 문자로 동시에 표시합니다.

아니요, 예상됩니다. 여러 스레드의 일반적인 비동기 동작을 보여줍니다. 생산자는 소비자가 자고있는 동안 2 개의 편지를 낼 수있었습니다.

특히 생산자와 소비자 모두가 무작위로 잠을하고 있다는 생각이 일어날 것입니다 :

Thread.sleep((int) (Math.random() * 300)); 

그러나 심지어 잠 않고는, 비대칭 동작은 스레드 프로그램을 것으로 예상된다.

Answer 3

이것은 버그입니까?

응답 - 아니오 불필요한 수면을 추가하기 때문에 발생합니다.

Thread.sleep((int) (Math.random() * 300)); 

다음 Producer 소비자 버전이 단순화되었습니다.

public class Example { 

public static class Producer implements Runnable { 
    private PriorityBlockingQueue<Character> queue; 

    Producer(PriorityBlockingQueue<Character> queue) { 
     this.queue = queue; 
    } 

    public void run() { 
     char ch; 
     for (ch = 'a'; ch <= 'f'; ch++) { 
      queue.put(ch); 
     } 
    } 
} 

public static class Consumer implements Runnable { 

    private PriorityBlockingQueue<Character> queue; 

    Consumer(PriorityBlockingQueue<Character> queue) { 
     this.queue = queue; 
    } 

    public void run() { 
     for (int i = 0; i < 7; i++) { 
      try { 
       System.out.println("Consumer take :" + queue.take()); 
      } catch (InterruptedException e) { 
       Thread.currentThread().interrupt();// Propagate interrupt 
      } 
     } 
    } 
} 

public static void main(String[] args) { 
    ExecutorService executorService = Executors.newFixedThreadPool(2); 
    PriorityBlockingQueue<Character> queue = new PriorityBlockingQueue<Character>(7); 
    executorService.execute(new Producer(queue)); 
    executorService.execute(new Consumer(queue)); 
    executorService.shutdown(); 
} 

}