首页 | 源码下载 | 网站模板 | 网页特效 | 广告代码 | 网页素材 | 字体下载 | 书库 | 站长工具
会员投稿 投稿指南 RSS订阅
当前位置:主页>网络编程>java教程>资讯:Java实现的线程池、消息队列功能方法

Java实现的线程池、消息队列功能方法

www.jz123.cn  2010-03-01   来源:   中国建站    责任编辑(袁袁)    我要投递新闻

 

 private ThreadPoolManager(){}
  private boolean hasMoreAcquire()
  {
  return !msgQueue.isEmpty();
  }
  public void addLogMsg( String msg )
  {
  Runnable task = new AccessDBThread( msg );
  threadPool.execute( task );
  }
  }
  public class AccessDBThread implements Runnable
  {
  private String msg;
  public String getMsg()
  {
  return msg;
  }
  public void setMsg( String msg )
  {
  this.msg = msg;
  }
  public AccessDBThread(){
  super();
  }
  public AccessDBThread(String msg){
  this.msg = msg;
  }
  public void run()
  {
  // 向数据库中添加Msg变量值
  System.out.println("Added the message: "+msg+" into the Database");
  }
  }
  public class TestDriver
  {
  ThreadPoolManager tpm = ThreadPoolManager.newInstance();
  public void sendMsg( String msg )
  {
  tpm.addLogMsg( msg + "记录一条日志 " );
  }
  public static void main( String[] args )
  {
  for( int i = 0; i < 100; i++ )
  {
  new TestDriver().sendMsg( Integer.toString( i ) );
  }
  }
  }

上一篇:Hibernate的一级缓存简介 下一篇:Java Applet程序设计基础

评论总数:0 [ 查看全部 ] 网友评论


关于我们隐私版权广告服务友情链接联系我们网站地图