Java并发编程(六) 一个日志服务的例子

            public
            class
             LogService
{
   
            private
            final BlockingQueue<String> msgQueue;         //阻塞的消息队列保存日志消息
   privatefinal PrintWrite writer;                      //写消息到日志文件
   privatefinal LoggerThread logThread;                 //写日志的线程
   privateboolean isShutdown;                           //表示日志服务是否已经关闭

   public LogService(String file) throws FileNotFoundException
   {
      logThread = new LogThread();
      writer = new PrintWrite(file);
   }

   publicvoid start()
   {
       logThread.start();                                           //启动日志线程
       Runtime.getRuntime().addShutdownHook(new Thread() {          //添加关闭钩子，确保在没有调用stop方法的情况下，日志文件最终仍然会关闭
                 stop();
       });
   }

   publicvoid stop()
   {
       synchronized(this)                                //需要先加锁，再修改isShutdown的值
       {
            if(!isShutdown)
            {
                isShutdown = true;
                logThread.interrupt();                 //中断日志线程
            }
       }
   }

  publicvoid  log(String message)
  {
      synchronized(this)                                //需要先加锁，再访问isShutdown的值
      {
          if(!isShutdown)                               //若日志服务没有关闭，则将消息加入消息队列，这里是典型的先验条件，声明isShutdown为volatile并不能解决同步的问题
             msgQueue.put(message);
          elsethrownew IllegalStateException("Log Service is shutdown");    //若日志服务已经关闭，则抛出IllegalStateException
      }
  }

   privateclass  LoggerThread extends Thread
   {
      publicvoid run()
      {
            try
            {
              while(true)
              {
                 try
                 {
                    synchronized(LogService.this)
                    {
                       if(isShutdown && msgQueue.size() == 0)          //如果服务已经关闭并且消息队列中已经没有剩余的消息，则关闭日志线程
                          break;
                       writer.write(msgQueue.take());
                    }
                 }
                 catch(InterruptedException ex){}                     //忽略中断消息
              }
            }
            finally
           {
              writer.close();                                         //关闭日志文件
           }
      }
  }
   
}