Ò׽ؽØͼÈí¼þ¡¢µ¥Îļþ¡¢Ãâ°²×°¡¢´¿ÂÌÉ«¡¢½ö160KB

java¶àÏ̵߳ÄЧÂʾÍÒ»¶¨¸ßÂð£¿

   ºÜ¾ÃûÉÏÀ´ÁË£¬·¢ÏÖËäÈ»×ÊÁϺÍÊé¿´µÄºÜ¶à£¬µ«ÊǺܾÃûÅöµÄ¶«Î÷»¹ÊǺÜÈÝÒ×µ­Íü¡£ÒÔºóÏ£ÍûÄܶà¼Ç¼°É¡£
   ½ñÌìÍæÁË°ÑÏ̳߳أ¬²¢¶ÔÆäÖеIJÎÊý×öÁËһЩµ÷Õû£¬²¢¼Ç¼Ôڶಢ·¢Çé¿öÏÂÏß³ÌÊý¶Ô¸÷ÖÖÇé¿öµÄ·´Ó¦¡£³ÌÐòÊÇÍøÉÏÕҵģ¬²¢×÷ÁËÉÔ΢Ð޸ġ£
javaµÄÏ̳߳ØʵÏÖ£¬ThreadPool
package net.zj.hz.yk.threadpool;
import java.util.LinkedList;
public class ThreadPool extends ThreadGroup {
private boolean isClosed = false; // Ï̳߳ØÊÇ·ñ¹Ø±Õ
private LinkedList workQueue; // ¹¤×÷¶ÓÁÐ
private static int threadPoolID = 1; // Ï̳߳صÄid
public ThreadPool(int poolSize) {
super(threadPoolID + "");// Ö¸¶¨ThreadGroupµÄÃû³Æ
setDaemon(true); // ¼Ì³Ðµ½µÄ·½·¨£¬ÉèÖÃÊÇ·ñÊØ»¤Ï̳߳Ø
workQueue = new LinkedList(); // ´´½¨¹¤×÷¶ÓÁÐ
for (int i = 0; i < poolSize; i++) {
new WorkThread(i).start(); // ´´½¨²¢Æô¶¯¹¤×÷Ïß³Ì,Ï̳߳ØÊýÁ¿ÊǶàÉپʹ´½¨¶àÉÙ¸ö¹¤×÷Ïß³Ì
}
}
/** µÈ´ý¹¤×÷Ḭ̈߳ÑËùÓÐÈÎÎñÖ´ÐÐÍê±Ï */
public void waitFinish() {
synchronized (this) {
isClosed = true;
notifyAll(); // »½ÐÑËùÓл¹ÔÚgetTask()·½·¨ÖеȴýÈÎÎñµÄ¹¤×÷Ïß³Ì
}
// activeCount() ·µ»Ø¸ÃÏß³Ì×éÖлÏ̵߳ĹÀ¼ÆÖµ¡£
Thread[] threads = new Thread[activeCount()];
// enumerate()·½·¨¼Ì³Ð×ÔThreadGroupÀ࣬¸ù¾Ý»î¶¯Ï̵߳ĹÀ¼ÆÖµ»ñµÃÏß³Ì×éÖе±Ç°ËùÓлµÄ¹¤×÷Ïß³Ì
int count = enumerate(threads);
for (int i = 0; i < count; i++) { // µÈ´ýËùÓй¤×÷Ï߳̽áÊø
try {
threads[i].join(); // µÈ´ý¹¤×÷Ï߳̽áÊø
} catch (InterruptedException ex) {
ex.printStackTrace();
}
}
}
/** ¹Ø±ÕÏß³Ì³Ø */
public synchronized void closePool() {
if (!isClosed) {
// µÈ´ý¹¤×÷Ïß³ÌÖ´ÐÐÍê±Ï
waitFinish();
isClosed = true;
// Çå¿Õ¹¤×÷¶ÓÁÐ
workQueue.clear();
// ÖжÏÏ̳߳ØÖеÄËùÓеŤ×÷Ïß³Ì,´Ë·½·¨¼Ì³Ð×ÔThreadGroupÀà
interrupt();
}
}
/** Ïò¹¤×÷¶ÓÁÐÖмÓÈëÒ»¸öÐÂÈÎÎñ,Óɹ¤×÷Ïß³ÌÈ¥Ö´ÐиÃÈÎÎñ */
public synchronized void execute(Runnable task) {
if (isClosed) {
throw new IllegalStateException();
}
if (task != null) {
// Ïò¶ÓÁÐÖмÓÈëÒ»¸öÈÎÎñ


Ïà¹ØÎĵµ£º

Ò»¸ö¼òµ¥µÄjavaרÓöÔÏó³Ø

package com.word.tools.pool;
import java.util.Vector;
import com.word.po.ObjectPool_Param;
import com.word.po.TyjkXmlPO;
public class TyjkXmlPool
{
    /**¶ÔÏó³Ø²ÎÊý*/
    private ObjectPool_Param ob_param;
    /**´æ·Å¶ÔÏóµÄVector*/
   ......

java Map ±éÀúËÙ¶È×îÓŽâ

µÚÒ»ÖÖ:
Map map = new HashMap();
Iterator iter = map.entrySet().iterator();
while (iter.hasNext()) {
Map.Entry entry = (Map.Entry) iter.next();
Object key = entry.getKey();
Object val = entry.getValue();
}
ЧÂʸß,ÒÔºóÒ»¶¨ÒªÊ¹ÓôËÖÖ·½Ê½£¡
µÚ¶þÖÖ:
Map map = new HashMap();
Iterator iter = ma ......

ÖÂJavaÐÂÊÖµÄÒ»·âЊת

ÏÂÃæÕâƪÎÄÕÂÊÇ̨ÍåÖøÃûJavaÂÛ̳“Javaworld”µÄÒ»¸ö×ÊÉî°æÖ÷дµÄÒ»·â¶ÔJavaÐÂÊÖµÄÐÅ£¬Ï£ÍûС×é³ÉÔ±×Ðϸ¿´Ï Äã»áѧµ½ºÜ¶àµÄ¡¢¡¢¡¢¡¢
親愛µÄ java ÐÂÊÖ們 :
ºÜ¸ß興Äã們願Òâ來這裡¹²Í¬學習,
Java 這個語ÑÔ, Ò ......

Java ´óСд²»Ãô¸ÐÌæ»»

public static void replaceString(String source,String oldStr,String newStr){
          System.out.println(source);
          String result = source.replaceAll("(?i)"+oldStr
, newStr); //´óСд²»Ãô ......

JAVAÏ̳߳صÄʹÓÃ

Ï̳߳ØÀàΪ java.util.concurrent.ThreadPoolExecutor£¬³£Óù¹Ôì·½·¨Îª£º ThreadPoolExecutor(int corePoolSize, int maximumPoolSize,
long keepAliveTime, TimeUnit unit,
BlockingQueue<Runnable> workQueue,
RejectedExecutionHandler handler) corePoolSize£º Ï̳߳Øά»¤Ï̵߳Ä×îÉÙÊýÁ¿ ......
© 2009 ej38.com All Rights Reserved. ¹ØÓÚE½¡ÍøÁªÏµÎÒÃÇ | Õ¾µãµØͼ | ¸ÓICP±¸09004571ºÅ