src/mfw/pool/newer/MissionThreadAtom.java

   1 /**
   2  *    Copyright 2011 Huize Dai <geb.1989@gmail.com>
   3  *
   4  *    This file is part of MFW.
   5  *
   6  *    MFW is free software: you can redistribute it and/or modify
   7  *    it under the terms of the GNU Lesser General Public License as published by
   8  *    the Free Software Foundation, either version 3 of the License, or
   9  *    (at your option) any later version.
  10  *
  11  *    MFW is distributed in the hope that it will be useful,
  12  *    but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  *    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14  *    GNU Lesser General Public License for more details.
  15  *
  16  *    You should have received a copy of the GNU Lesser General Public License
  17  *    along with MFW.  If not, see <http://www.gnu.org/licenses/>.
  18  */
  19 package mfw.pool.newer;
  20
  21 public class MissionThreadAtom extends Thread implements MissionThread {
  22
  23         private Runnable task = null;
  24         private boolean isContinue = true;
  25
  26         MissionThreadAtom() {
  27         }
  28
  29         public synchronized boolean run(Runnable task) {
  30                 if (task == null) {
  31                         this.task = task;
  32                         this.notify();
  33                         return true;
  34                 } else {
  35                         return false;
  36                 }
  37         }
  38
  39         public void run() {
  40                 while (isContinue) {
  41                         synchronized (this) {
  42                                 if (task == null) {
  43                                         try {
  44                                                 this.wait();
  45                                         } catch (InterruptedException ex) {
  46                                         }
  47                                 }
  48                         }
  49                         if (task != null) {
  50                                 task.run();
  51                                 task = null;
  52                         }
  53                 }
  54         }
  55
  56         public synchronized void cancel() {
  57                 isContinue = true;
  58                 if (task == null)
  59                         this.notify();
  60         }
  61 }