Java多線程消費者、生產者的基本思路

阿新 • • 發佈：2019-02-12

func don 判斷 this 定義 oid final zed ()

多線程主要考察的就是線程的同步控制生產者消費者的思路就是，當一個線程執行時讓另一個線程掛起就行了

ThreadOne、ThreadTwo同時運行，添加一個變量在一個公共類（下邊的Function類）中，

例如：當變量為true，ThreadOne執行ThreadTwo掛起；

當變量為false，ThreadOne掛起ThreadTwo執行

一個線程執行完之後，自己重置變量（目的是把自己掛起），然後喚醒另一個掛起的線程，如此便可使兩個線程交替執行

對於消費者、生產者來說：

當消費者拿不到東西的時候就把自己掛起，並且喚醒生產者就可以了

當生產者生產完東西的時候就把自己掛起，並且喚醒消費者就可以了

//這是一個共享的類，主線程和子線程共用
    class Function{
        private boolean flag=false;
        //子線程要實現的功能
        public synchronized void sub(){
            while(flag){  //此處用while循環而不是用if語句判斷是為了防止 線程的假喚醒
                try {
                    this.wait(); //此處的this指的是當前執行此段代碼的線程 

                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }

            for(int i=0;i<10;i++){
                //for循環內定義子線程的功能,這裏簡單的假設為打印一句話,主線程同理
                System.out.println("sub"+i);
            }

            flag=true;
             
this.notify();
        }
        //主線程要實現的功能
        public synchronized void main(){
            while(!flag){ //此處用while循環是為了 防止線程的假喚醒
                try {
                    this.wait(); //此處this指的是當前執行此段代碼的線程
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            for(int i=0;i<10;i++){
                System.out.println("main"+i);
            }

            flag=false;
            this.notify();
        }

    }

    public class Demo01 {

        public static void main(String[] args) {
            final Function f=new Function();
            new Thread(
                    new Runnable(){

                        @Override
                        public void run() {
                            for(int i=0;i<50;i++){
                                f.sub();
                            }
                        }

                    }
            ).start();

            for(int i=0;i<50;i++){
                f.main();
            }
        }
    }

Java多線程消費者、生產者的基本思路

func don 判斷 this 定義 oid final zed () 多線程主要考察的就是線程的同步控制生產者消費者的思路就是，當一個線程執行時讓另一個線程掛起就行了 ThreadOne、ThreadTwo同時運行，添加一個變量在一個公共類（下邊的F

【轉載】JAVA多線程讀取、操作List集合

線程 nbsp static 一點 stat lang 素數 param 應用本文轉載自：http://blog.csdn.net/wang1989cs/article/details/47663565 import java.util.ArrayList; impor

Java多線程_生產者消費者模式1

多線程 ren 範例結果 div 之間 trace left 平衡生產者消費者模型具體來講，就是在一個系統中，存在生產者和消費者兩種角色，他們通過內存緩沖區進行通信，生產者生產消費者需要的資料，消費者把資料做成產品。生產消費者模式如下圖。（圖片來自網絡，侵

“全棧2019”Java多線程第二十五章：生產者與消費者線程詳解

工程 java 技術分享初級計劃公眾圖片進步 www. 難度初級學習時間 10分鐘適合人群零基礎開發語言 Java 開發環境 JDK v11 IntelliJ IDEA v2018.3 文章原文鏈接 “全棧2019”Java多線程第二十五章：生產者與

“全棧2019”Java多線程第三十九章：顯式鎖實現生產者消費者模型

href write 聲明分享圖片全棧工程師 tel 技術我們更多難度初級學習時間 10分鐘適合人群零基礎開發語言 Java 開發環境 JDK v11 IntelliJ IDEA v2018.3 文章原文鏈接 “全棧2019”Java多線程第三十九章

Java多線程編程：Callable、Future和FutureTask淺析

創建線程執行過程 data- body javase 接下來而後定義通過前面幾篇的學習，我們知道創建線程的方式有兩種，一種是實現Runnable接口，另一種是繼承Thread，但是這兩種方式都有個缺點，那就是在任務執行完成之後無法獲取返回結果，那如果我們想要獲取返

java多線程_01_線程的基本概念

bool 我們優先 try 立即執行合並 abcde rup unix 線程：一個程序裏邊不同的執行路徑例子程序：這個例子程序是一條執行路徑。這個程序只有一個分支，就是main方法，叫主線程 public static void main(String[]

Java 多線程系列2——多線程的生命周期及生產消費者模型

wait 重要 strong clas 經典關於 running 結束準備一、線程的生命周期及五種基本狀態關於Java中線程的生命周期，首先看一下下面這張較為經典的圖：上圖中基本上囊括了Java中多線程各重要知識點。掌握了上圖中的各知識點，Java中的多

Java多線程（二） —— 線程安全、線程同步、線程間通信（含面試題集）

err 線程等待共同點 -c java多線能夠空間而不是不一致一、線程安全多個線程在執行同一段代碼的時候，每次的執行結果和單線程執行的結果都是一樣的，不存在執行結果的二義性，就可以稱作是線程安全的。講到線程安全問題，其實是指多線程環境下對共享資源的訪問可能會

Java多線程：CountDownLatch、CyclicBarrier 和 Semaphore

Java多線程簡析——Synchronized（同步鎖）、Lock以及線程池

ati auto bsp lock eas 根據引入封裝 util Java多線程 Java中，可運行的程序都是有一個或多個進程組成。進程則是由多個線程組成的。最簡單的一個進程，會包括mian線程以及GC線程。線程的狀態線程狀態由以下一張網上圖片來說明：

C#多線程學習(三) 生產者和消費者

... new col 線程簡單的 ons finally 訪問 read 前面說過，每個線程都有自己的資源，但是代碼區是共享的，即每個線程都可以執行相同的函數。這可能帶來的問題就是幾個線程同時執行一個函數，導致數據的混亂，產生不可預料的結果，因此我們必須避免這種情況的發

Java實現多線程下載、斷點續傳

get import 服務結束 parseint RR range turn con 開三個線程下載，代碼： package demo; import java.io.InputStream; import java.io.RandomAccessFile; impo

【java多線程】（3）---synchronized、Lock

arraylist arr nal 調用 BE [] div 請求 timeunit synchronized、Lock 一、概述 1、出現線程不安全的原因是什麽？如果我們創建的多個線程，存在著共享數據，那麽就有可能出現線程的安全問題：當其中一個

JAVA 多線程制作大球吃小球一、實現球的自動生成及運動生產消費模型

生產者 tar thread ive 聯系 print random 線程 ram /*文章中用到的代碼只是一部分，需要源碼的可通過郵箱聯系我 [email protected]*/ 前幾天用多線程實現了創建小球並移動，想到大魚吃小魚，便突發奇想要寫一個大球吃小球。首先第一

java 多線程的基本概念

java 概念操作進程多線程數據進行發生程序進程：進程是操作系統結構的基礎，是程序的一次運行，是一個程序及其數據在處理機上順序執行時所發生的活動，是程序在一個數據集合上運行的過程，它是系統進行資源分配和調度的一個單位線程：線程是程序執行的一

Java多線程的基本知識

rri vm虛擬機 alt 時間工具 interrupt 所有回收 thead 1、進程與線程進程是指一個程序的執行過程，持有資源和線程線程是系統中最小的執行單元，一個進程可以有多個線程，線程共享進程資源，具有同步（線程的協作）與互斥（資源的爭搶）例如：我們一個

【Python爬蟲學習筆記10】多線程中的生產者消費者模式

其中因此問題共享 and 生產者消費者模式共享問題由於接下來在多線程編程中，最經典的模式是生產者消費者模式。其中，生產者是專門用來生產數據的線程，它把數據存放在一個中間變量中；而消費者則從這個中間變量取出數據進行消費。由於生產者和消費者共享中間變量，這些變量大

多線程----簡單的生產者和消費者

一個 sum @override () ride pac .com lock -- package cn.zz; //簡單的生產者和消費者class Resource { private String name; private int count; private boo

java——多線程的實現方式、兩種辦法解決線程賽跑

ble ali ide live nts nds extends sys add 多線程的實現方式：demo1、demo2 demo1：繼承Thread類，重寫run()方法 package thread_test; public class ThreadDemo1 e

Java多線程消費者、生產者的基本思路

相關推薦