background image

  task.run();
  }
  }
  

protected

 SyncQueue _queue = 

null

;

  }
 
  下面是一个使用这个 Thread 缓冲池的例子:
  

//构造 Thread 缓冲池

 
  SyncQueue queue = 

new

 SyncQueue(

10

);

  

for

 (

int

 i = 

0

; i < 

5

; i ++) {

  

new

 Thread(

new

 Worker(queue)).start();

  }
  

//使用 Thread 缓冲池

 
  Runnable task = 

new

 MyTask();

  queue.put(task);
 
  为了使本文中的代码尽可能简单,这个 Thread 缓冲池的实现是一个基本的框架。当
使用到实际中时,一些其他功能也可以在这一基础上添加,比如异常处理,动态调整缓
冲池大小等等。