實(shí)驗(yàn)內(nèi)容：
以讀者訂閱報(bào)刊雜志為背景，體驗(yàn)多線程生產(chǎn)/訂閱模式下的經(jīng)典應(yīng)用。
具體業(yè)務(wù)描述：
本實(shí)驗(yàn)以實(shí)際生活中報(bào)刊雜志的訂閱為業(yè)務(wù)背景。訂閱者通常有很多種，他們可以
同時(shí)向出版社發(fā)出訂閱申請(qǐng)； 出版社通常根據(jù)自身的資源條件對(duì)收到的訂閱申請(qǐng)做統(tǒng)
一的處理；出版社通常能接受并處理的訂閱申請(qǐng)量是有一定限度的；出版社匯總訂閱申
請(qǐng)信息后交由獨(dú)立業(yè)務(wù)單元處理，直至完畢；本業(yè)務(wù)主要是模擬多讀者同時(shí)訂閱、信息
匯總后再行處理的業(yè)務(wù)情景。
本實(shí)驗(yàn)的關(guān)鍵業(yè)務(wù)概念：
1） 訂閱者，即訂閱信息生產(chǎn)者，向共享池中放入訂閱信息；
2） 信息匯總，即訂閱信息共享池，生產(chǎn)者和消費(fèi)者共用；
3） 業(yè)務(wù)單元，即訂閱信息消費(fèi)者，處理訂閱者生產(chǎn)的訂閱信息。
創(chuàng)建工程并配置環(huán)境：
1） 工程名：SE_JAVA_EXP_E03。
2） 創(chuàng)建包，取名：cn.com.java.experiment 和 cn.com.java.experiment.entity。
3） 在 包 cn.com.java.experiment.entity 下 創(chuàng)建訂閱信息共享池業(yè)務(wù)類：SharePool。

• 設(shè)置兩個(gè)屬性，只為 pool 屬性實(shí)現(xiàn) setter/getter 方法；
  

• 為 SharePool 類創(chuàng)建構(gòu)造器，初始化最大限量的訂閱信息；

• 創(chuàng)建生成訂閱信息的方法 produce，由訂閱者調(diào)用，生成訂閱信息并完成訂閱信息的提交，實(shí)現(xiàn)要求如下：
  1.應(yīng)用同步機(jī)制控制本方法的實(shí)現(xiàn)；
  2.獲取當(dāng)前訂閱信息共享池的信息數(shù)量；
  3.當(dāng)共享池信息數(shù)量等于最大訂閱量時(shí)，輸出如下信息并開(kāi)始等待：“訂閱請(qǐng)求隊(duì)列已滿，等待系統(tǒng)處理訂閱請(qǐng)求中……”
  4.當(dāng)共享池信息數(shù)量小于最大訂閱量時(shí)：把訂閱信息加入到共享池；在控制臺(tái)輸出如下格式的信息：“訂閱者@”+當(dāng)前線程名+":訂閱《" + media + “》申請(qǐng)已提交.當(dāng)前訂閱數(shù)量為：” + 訂閱數(shù)量；發(fā)出完成訂閱申請(qǐng)的通知。

• 創(chuàng)建處理訂閱信息的方法 consum，由訂閱信息消費(fèi)者調(diào)用，完成訂閱信
  息的處理。實(shí)現(xiàn)要求如下：
  1…應(yīng)用同步機(jī)制控制本方法的實(shí)現(xiàn)；
  2.獲取當(dāng)前訂閱信息共享池的信息數(shù)量；
  3.當(dāng)共享池信息數(shù)量等于 0 時(shí)，輸出如下信息并開(kāi)始等待：“處理者@” +當(dāng)前線程名稱+“暫無(wú)訂閱請(qǐng)求信息，等待中……”
  4.當(dāng)共享池信息數(shù)量不為 0 時(shí)：從訂閱共享池移除一項(xiàng)訂閱信息；在控制臺(tái)輸出如下格式的信息：“處理者@”+當(dāng)前線程名+":處理《" + 移除訂閱信息 + “》訂閱已完畢。尚待處理訂閱數(shù)量為：” + 剩余訂閱數(shù)量；發(fā)出完成訂閱處理的通知。

4） 在 cn.com.java.experiment.entity 包中創(chuàng)建訂閱信息生產(chǎn)者業(yè)務(wù)類：Producer

• Producer 類需要實(shí)現(xiàn)線程類接口 Runnable，并且實(shí)現(xiàn) run 方法；

• 為 Producer 類創(chuàng)建訂閱信息共享池屬性，要求如下：
  

• 為 Producer 類創(chuàng)建構(gòu)造器；

• 為 Producer 類實(shí)現(xiàn)生產(chǎn)訂閱信息的 run 方法，以產(chǎn)生指定數(shù)量訂閱信息并
  存放到訂閱共享池中。實(shí)現(xiàn)要求如下：
  1.模擬輸出訂閱者相關(guān)信息，格式如下： “訂閱者@”+當(dāng)前線程名稱+“：訂閱”+訂閱數(shù)量+“份。”；
  2.通過(guò)循環(huán)方式發(fā)出所有指定數(shù)量的訂閱請(qǐng)求：當(dāng)訂閱數(shù)量發(fā)送完畢后，結(jié)束訂閱并輸出如下信息： “訂閱者@”+當(dāng)前線程名稱+“->完成訂閱。”定義計(jì)數(shù)器，把信息放入到訂閱信息共享池并輸出如下信息：“訂閱者@”+當(dāng)前線程名稱+“ 在提交第”+計(jì)數(shù)器+“ 份訂閱申請(qǐng)。”讓當(dāng)前線程休眠半秒鐘；訂閱完畢后退出方法。

5） 在 cn.com.java.experiment.entity 包中創(chuàng)建訂閱信息處理者業(yè)務(wù)類：Consumer

• Consumer 類需要實(shí)現(xiàn)線程類接口 Runnable，并且實(shí)現(xiàn) run 方法；

• 為 Consumer 類創(chuàng)建訂閱信息共享池屬性，要求如下：

• 為 Consumer 類創(chuàng)建構(gòu)造器；

• 為 Consumer 類實(shí)現(xiàn)生產(chǎn)訂閱信息的 run 方法，產(chǎn)生指定數(shù)量的訂閱信息并存放到訂閱信息共享池中。實(shí)現(xiàn)要求如下：
  1.創(chuàng)建處理訂閱信息數(shù)量的計(jì)數(shù)器；
  2.通過(guò)循環(huán)方式處理共享池內(nèi)的所有訂閱信息：啟動(dòng)計(jì)數(shù)器，當(dāng)計(jì)數(shù)器大于15 時(shí)，結(jié)束處理并輸出如下信息：“本線程完成訂閱處理量，即刻退出。處理者@”+當(dāng)前線程名稱；當(dāng)計(jì)數(shù)器小于 15 時(shí)，處理共享池內(nèi)的訂閱信息并輸出如下信息：“訂閱者@”+當(dāng)前線程名稱+“ ：處理第”+計(jì)數(shù)器+“ 份訂閱。”處理全部完成后，退出信息訂閱池。

6） 在包 cn.com.java.experiment 下創(chuàng)建主類：MainClass，模擬現(xiàn)實(shí)生產(chǎn)/處理的結(jié)
果。

為 MainClass 創(chuàng)建入口主方法：main；

在 main 中，創(chuàng)建 1 個(gè)訂閱信息共享池對(duì)象；

在 main 中，創(chuàng)建 5 個(gè)不同的訂閱者，訂閱總量為 15，共用共享池；

main 中，創(chuàng)建 1 個(gè)訂閱處理類對(duì)象，處理所有提交的訂閱信息。

代碼
Mainclass

package cn.com.java.experiment;import cn.com.java.experiment.entity.Consumer; import cn.com.java.experiment.entity.Producer; import cn.com.java.experiment.entity.SharePool;public class MainClass {public static void main(String[] args) {SharePool pool = new SharePool();for (int i = 1; i <= 5; i++) {new Thread(new Producer(pool, i)).start();}new Thread(new Consumer(pool)).start();} }

Consumer

package cn.com.java.experiment.entity;public class Consumer implements Runnable {private SharePool pool;public Consumer() {super();}public Consumer(SharePool pool) {super();this.pool = pool;}public void run() {int counts = 1;while(true){if(counts <= 15) {System.out.println("處理者@" + Thread.currentThread().getName() + ":處理第" + counts + "份訂閱。");this.pool.consume();}else{System.out.println("本線程完成訂閱處理量，即刻退出。處理者@" + Thread.currentThread().getName());break;}counts++;}} }

Producer

package cn.com.java.experiment.entity;public class Producer implements Runnable {private SharePool pool; private int count; public Producer() {super();}public Producer(SharePool pool, int count) {super();this.pool = pool;this.count = count;}public void run() {String infor = "報(bào)刊雜志";int counts = 0;System.out.println("訂閱者@" + Thread.currentThread().getName() + "：訂閱" + count + "份。");while (count > 0) {counts++;System.out.println("訂閱者@" + Thread.currentThread().getName() + " 在提交第" + counts + " 份訂閱申請(qǐng)。");pool.produce(infor + counts);count--;try {Thread.sleep(500);} catch (InterruptedException e) {e.printStackTrace();}}System.out.println("訂閱者@" + Thread.currentThread().getName() + "->完成訂閱。");} }

Sharepool

package cn.com.java.experiment.entity;import java.util.ArrayList; import java.util.List;public class SharePool {private List<String> pool=new ArrayList(); private final int MAX=15; public List<String> getPool(){return pool;}public void setPool(List<String> pool) {this.pool = pool;}public SharePool() {super();}public void produce(String infor) {synchronized (this) {if (pool.size() == MAX) {try {wait();} catch (InterruptedException e) {e.printStackTrace();}System.out.println("訂閱請(qǐng)求隊(duì)列已滿，等待系統(tǒng)處理訂閱請(qǐng)求中......");}else {pool.add(infor);System.out.println("訂閱者@" + Thread.currentThread().getName() + ":訂閱《" + infor + "》申請(qǐng)已提交.當(dāng)前訂閱數(shù)量為：" + pool.size());try{notify();}catch(Exception e ) {e.printStackTrace();}}}}public void consume() {synchronized (this) {if (pool.size() == 0) {try {wait();} catch (InterruptedException e) {e.printStackTrace();}System.out.println("處理者@" + Thread.currentThread().getName() + "暫無(wú)訂閱請(qǐng)求信息，等待中......");}else {String infor = pool.remove(0);System.out.println("處理者@" + Thread.currentThread().getName() + ":處理《" + infor + "》訂閱已完畢。尚待處理訂閱數(shù)量為：" + pool.size());try{notify();}catch(Exception e) {e.printStackTrace();}}}} }

截圖

總結(jié)

以上是生活随笔為你收集整理的JAVA——附加作业3——订阅报刊杂志的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。