이 글에서는 주로 Java의 BlockingQueue 차단에 대한 자세한 설명과 예시를 소개합니다. 필요한 친구는
Java의 차단 큐 BlockingQueue에 대한 자세한 설명과 예시
BlockingQueue는 다중 스레드의 데이터 전송에 대한 좋은 솔루션입니다. 우선 BlockingQueue는 대략 4개의 구현 클래스를 가지고 있습니다. 이는 BlockQueue가 비어 있는 경우 작업이 수행되는 방식입니다. BlockingQueue에서 항목을 가져오는 작업은 차단되고 대기 상태로 들어가며 BlockingQueue에 항목이 포함될 때까지 깨어나지 않습니다. 마찬가지로 BlockingQueue가 가득 차면 여기에 항목을 저장하려는 모든 작업도 차단됩니다. 대기 상태로 들어가며 BlockingQueue에 공간이 생길 때까지 깨어나지 않고 작업을 계속합니다.BlockingQueue의 네 가지 구현 클래스:
1.ArrayBlockingQueue: 지정된 크기의 BlockingQueue 생성자는 크기를 나타내기 위해 int 매개변수를 사용해야 합니다. FIFO(선입선출) 순서로 정렬됩니다.BlockingQueue의 일반적인 방법:
1) add(anObject): anObject를 추가합니다. BlockingQueue, 즉 BlockingQueue를 수용할 수 있으면 true를 반환하고 그렇지 않으면 예외가 보고됩니다.
예:
이 예는 주로 생산자와 소비자 간의 워크플로를 시뮬레이션하는 간단한 시나리오입니다. 생산자가 소비자가 소비할 제품을 생산할 때까지 기다립니다. 생산자:package com.gefufeng; import java.util.concurrent.BlockingQueue; public class Producter implements Runnable{ private BlockingQueue<String> blockingQueue; public Producter(BlockingQueue<String> blockingQueue){ this.blockingQueue = blockingQueue; } @Override public void run() { try { blockingQueue.put("我生产的" + Thread.currentThread().getName()); System.out.println("我生产的" + Thread.currentThread().getName()); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); System.out.println("生产失败"); } } }
소비자:
package com.gefufeng; import java.util.concurrent.BlockingQueue; public class Customer implements Runnable{ private BlockingQueue<String> blockingQueue; public Customer(BlockingQueue<String> blockingQueue){ this.blockingQueue = blockingQueue; } @Override public void run() { for(;;){ try { String threadName = blockingQueue.take(); System.out.println("取出:" + threadName); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); System.out.println("取出失败"); } } } }
package com.gefufeng; import java.util.concurrent.ArrayBlockingQueue; public class Executer { public static void main(String[] args) { ArrayBlockingQueue<String> arrayBlockingQueue = new ArrayBlockingQueue<String>(2); Producter producter = new Producter(arrayBlockingQueue); Customer cusotmer = new Customer(arrayBlockingQueue); new Thread(cusotmer).start(); for(;;){ try { Thread.sleep(2000); new Thread(producter).start(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } }
위 내용은 Java의 차단 대기열 BlockingQueue 예제에 대한 자세한 설명의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!