以下內容是根據本人的一些業(yè)務(wù)邏輯來(lái)做的一個(gè)dome,應該有很多地方還不完善,請大家看到的朋友可以指點(diǎn)一下程序的錯誤.
DBTest.java
package test.thread.test;
/**
* 模擬一個(gè)數據庫加載數據
*
* @author wangzi6hao
*/
public class DBTest {
/**
* 模擬初使化從數據庫中加次數據
*/
public static void initListObject() {
for (int i = 1; i <= 10; i++)
ListPool.list.add("linkedList" + i);
}
/**
* 模擬list數據快使用完成時(shí),再到數據庫中加載數據.
*
* @param count
* 添加的個(gè)數
*/
public static void addListObject(int count) {
String str = ListPool.list.getLast().replaceAll("linkedList", "");
int k = Integer.parseInt(str);
for (int i = 1; i <= count; i++) {
int j = k + i;
ListPool.list.add("linkedList" + j);
}
System.out.println("增加list后的大小:" + ListPool.list.size());
}
/**
* 刪除list數據
*/
public static void removeListObject() {
ListPool.list.remove(0);
System.out.println("刪除一個(gè)list后的大小:" + ListPool.list.size());
}
}
本文
地址：【伊甸網(wǎng)】
http://www.edenw.com/tech/devdeloper/java/2010-12-17/6857.html===========================================================
ListPool.java
package test.thread.test;
import java.util.LinkedList;
public class ListPool {
public static LinkedList<String> list = new LinkedList<String>();// 定義全局數據存放位置
public final static int THREAD_COUNT = 10;// 定義最大啟動(dòng)線(xiàn)程個(gè)數
}
=============================================================
DoSomething.java
package test.thread.test;
public class DoSomething implements Runnable {
public void run() {
try {
while (true) {
System.out.println("第一次得到大小:" + ListPool.list.size());
while (ListPool.list.size() > 1) {// 必須保留最后一個(gè)，做為下一次更新時(shí)的起初id
String info = "";
synchronized (ListPool.list) {
info = ListPool.list.get(0);
DBTest.removeListObject();
System.out.println("第二次得到大小:" + ListPool.list.size());
if (ListPool.list.size() <= 5) {
DBTest.addListObject(5);// 模擬從數據庫中加載數據
}
}
System.out.println(info);// 打印出內容,在現實(shí)中模擬到其它地方實(shí)現邏輯處理
Thread.sleep((int) (Math.random() * 1000));//睡眠隨機的毫秒,實(shí)現中可以改成1或者10毫秒,適當的釋放資源給其它程序使用
}
System.out.println("測試執行");
Thread.sleep(6 * 1000);
DBTest.addListObject(5);
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
=================================================================
TestMain.java
import test.thread.test.DBTest;
import test.thread.test.DoSomething;
import test.thread.test.ListPool;
public class TestMain {
/**
* @param args
*/
public static void main(String[] args) {
DBTest.initListObject();
int threadCount = 1;
try {
while (threadCount < 1000) {// 必須保留最后一個(gè)，做為下一次更新時(shí)的起初id
System.out.println("線(xiàn)程個(gè)數:" + threadCount);
DoSomething doSomething = new DoSomething();
Thread thread = new Thread(doSomething);
//thread.setDaemon(true);//這里在tomcat或者其它的web應用程序方面啟動(dòng)線(xiàn)程時(shí)應該設置為true.在tomcat關(guān)閉的時(shí)候,線(xiàn)程也應該關(guān)閉.因為用戶(hù)線(xiàn)程是基于jvm的,如果不設置為true(守護線(xiàn)程),tomcat關(guān)閉的時(shí)候,線(xiàn)程還會(huì )在運行,那會(huì )消耗cpu與
內存的.
thread.setDaemon(false);//在main方法中,這里必須設置為用戶(hù)線(xiàn)程.因為設置為守護線(xiàn)程時(shí),main方法執行完畢線(xiàn)程也自動(dòng)退出了,事實(shí)上程序還沒(méi)有執行完成.
thread.start();
threadCount++;
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
