日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

在Java多線程的應(yīng)用中有狠多需要我們主要的事情，其中以Message類和Queue類最為重要。在使用的時候我們需要不斷的學(xué)習(xí)相關(guān)的知識，這樣才能熟練的掌握在Java多線程中相關(guān)的使用方法。

站在用戶的角度思考問題，與客戶深入溝通，找到平川網(wǎng)站設(shè)計與平川網(wǎng)站推廣的解決方案，憑借多年的經(jīng)驗，讓設(shè)計與互聯(lián)網(wǎng)技術(shù)結(jié)合，創(chuàng)造個性化、用戶體驗好的作品，建站類型包括：成都網(wǎng)站設(shè)計、成都網(wǎng)站建設(shè)、企業(yè)官網(wǎng)、英文網(wǎng)站、手機端網(wǎng)站、網(wǎng)站推廣、國際域名空間、虛擬空間、企業(yè)郵箱。業(yè)務(wù)覆蓋平川地區(qū)。

Message類

 
 
 

  
  
  
package com.example.test;  
  
  
  
public class Message {  
  
  
  
public static int id;  
  
  
  
public String content;  
  
  
  
public String getContent() {  
  
  
  
return content;  
  
  
  
}  
  
  
  
public void setContent(String content) {  
  
  
  
this.content = content;  
  
  
  
}  
  
  
  
public int getId() {  
  
  
  
return id;  
  
  
  
}  
  
  
  
public void setId(int id) {  
  
  
  
Message.id = id;  
  
  
  
}  
  
  
  
} 
 
 
 

 

Queue類

 
 
 

  
  
  
package com.example.test;  
  
  
  
import java.util.ArrayList;  
  
  
  
import java.util.List;  
  
  
  
public class Queue {  
  
  
  
List queue = new ArrayList();  
  
  
  
/** 隊列中message對象的***值,默認為5 */  
  
  
  
int maxMessageNum = 5;  
  
  
  
public synchronized void produce(Message message) {  
  
  
  
this.notifyAll();  
  
  
  
while (queue.size() == maxMessageNum) {  
  
  
  
System.out.println(Thread.currentThread().getName()  
  
  
  
+ " 隊列滿！等待中。");  
  
  
  
try {  
  
  
  
this.wait();  
  
  
  
} catch (InterruptedException e) {  
  
  
  
e.printStackTrace();  
  
  
  
}  
  
  
  
}  
  
  
  
queue.add(message);  
  
  
  
System.out.println(Thread.currentThread().getName() + "正在生產(chǎn)"  
  
  
  
+ message.getContent() + "。 ,當(dāng)前個數(shù):" + getCount());  
  
  
  
}  
  
  
  
public synchronized void consume() {  
  
  
  
this.notifyAll();  
  
  
  
while (queue.size() == 0) {  
  
  
  
System.out.println(Thread.currentThread().getName()  
  
  
  
+ " 隊列空！等待中。");  
  
  
  
try {  
  
  
  
System.out.println("begin!");  
  
  
  
wait();  
  
  
  
System.out.println("end!");  
  
  
  
} catch (InterruptedException e) {  
  
  
  
e.printStackTrace();  
  
  
  
}  
  
  
  
}  
  
  
  
Message message = queue.get(0);  
  
  
  
queue.remove(0);  
  
  
  
System.out.println(Thread.currentThread().getName() + "正在消費"  
  
  
  
+ message.getContent() + "。 ,當(dāng)前個數(shù): " + getCount());  
  
  
  
}  
  
  
  
public synchronized int getCount() {  
  
  
  
return queue.size(); 
 
 
 

以上就是對Java多線程的詳細介紹。相關(guān)的問題我們還是會不斷的向大家介紹。

分享標(biāo)題：Java多線程中Message類和Queue類的使用方法
URL網(wǎng)址：http://m.5511xx.com/article/ccssoje.html