1. Blockingqueue ??? Java Producer-Consumer ??? ???? ?? ????? ???? ?????. ????? ??? ???? ?????. ???? put () ???? ???? ?? ?? ?? ??? ???? ???? Take () ???? ???? ?? ???? ?????. 2. ?? ??? ??? ? ?? ? ??? ??? ?????? ????? ??/??/??? ???? ?? ??? ??? ???? ??? ?? ??? ?? ??? ????? ????. 3. ???? ????? ??? ??, Notifyall ()? ?????? ?? ??? ??? ? ??, ???? ?? ?? ?? ? ???? ?? ???? ?????.

Java Multithreaded ??????? ??? ??? ??? ???? ?? ???? ??? ?????. ?? ?? ??? ?? ?? ??? ???? ? ?? ?????. ?? ??? ???? ???? "??"? ???? ?? ??? ?? ???? "??"?? ??? ????.

? ??? ????? ??? ????? ???? ???? ???? ??? ?? ? ?? ?? ??? ??? ?????. ? ?? ???? ???? ???? ??? ???? ??? ?? ??????.

BlockingQueue ???? ?? ?? ???? ?????

Java? ??? BlockingQueue ????? (? : ArrayBlockingQueue ?? LinkedBlockingQueue )? ????, ?? ??? ??? ??? ????? ???? ??? ???? ???? ? ?? ???? ?????.

???? ?? ?? ?????.

• ???? put() ???? ???? ???? ?? ????.
• ???? take() ???? ???? ??? ???? ?????.

? ?? ?? ?? ???? ???? ?? ?? ???? ?????. ???? ?? ??? ???? ??? ????. ?? ??? ??? ??? ?????.

?? ?? ? ?? :

 blockingqueue <integer> queue = new Arrayblockingqueue <> (10);

// ??? ??? ? ??? (() -> {
    ???? {
        int i = 0;
        while (true) {
            ??? (i);
            System.out.println ( "?? :"I);
        }
    } catch (InterruptedException e) {
        thread.currentthread (). ???? ();
    }
}).??();

// ??? ??? ? ??? (() -> {
    ???? {
        while (true) {
            int value = queue.take ();
            System.out.println ( "?? :"?);
        }
    } catch (InterruptedException e) {
        thread.currentthread (). ???? ();
    }
}).??();

??? ?? ???? ??? ???? ?? ??? ?? ? ? ????.

BlockingQueue ? ???? ???? ??? ???? ??? ?? ????. ? ???? synchronized ??? ? wait/notify ????? ???? ??? ??? ???????.

?? ???? :

• ?? ??? ?? (? : List )? ??? ??????.
• ??? ??? ??
• ??? ?? ?? ??? ???? ?????. ????? ? ?????
• ??? ?? ??? ??? ???? ?????. ??? ???? ??? ? ??? ?????

?? :

• ? ????? ? ???? ???? ??? ???????.
• ?? wait() ? notify() ??? ???? ???????.

Pseudocode ?? :

 ?? ??? SharedBuffer {
    ??? ?? <integer> buffer = new ArrayList <> ();
    ?? ?? int max_size = 10;

    Public Synchronized Void Put (int value) Throws InterruptedException {
        while (buffer.size () == max_size) {
            ????();
        }
        buffer.add (?);
        notifyall ();
    }

    public synchronized int take () throws InterruptedException {
        while (buffer.isempty ()) {
            ????();
        }
        int ? = buffer.remove (0);
        notifyall ();
        ?? ?;
    }
}

???? ??? ??? ?? ??

• ???? ?? : ???? ?? ? ? ????. InterruptedException ???? ???? ??? ???????.
• ?? ????/??? ????? ??? ? ?? : ???? ?? ?? ???? ?? notifyAll() ?? () ?? notify() ???? ??? ?? ???? ???????.
• ???? ?? ?? ?? : ?? ? ???? ???? ?? ??? ??? ?? ??? ? ????.
• ???? ?? ??? : ?? ??? ?? ??? ???? ?? ?? ?? ?? ??? ??? ???? ?? ? ? ????.

????? ?? ??. BlockingQueue ??? ??? ??? ? ??? ?? ??? ?? ????? ???? ? ??? ? ? ????. ? ?? ???? ?? ?? ??? ????? ????. ??? ??? ???? ????? ???? ?? ????? ??? ? ????.

? ??? Java ???? ???? ??? ??? ??? ?????.? ?? ?????. ??? ??? PHP ??? ????? ?? ?? ??? ?????!