1 files changed, 133 insertions, 0 deletions
diff --git a/lib/mauve/mauve_thread.rb b/lib/mauve/mauve_thread.rb
new file mode 100644
index 0000000..f40c79c
--- /dev/null
+++ b/lib/mauve/mauve_thread.rb
@@ -0,0 +1,133 @@
+require 'thread'
+require 'singleton'
+
+module Mauve
+
+  class MauveThread
+
+    def initialize
+    end
+
+    def logger
+      Log4r::Logger.new(self.class.to_s) 
+    end
+
+    def run_thread(interval = 0.2)
+      #
+      # Good to go.
+      #
+      @frozen = false
+      @stop = false
+
+      logger.debug("Started")
+
+      @sleep_interval ||= interval
+
+      while !@stop do
+        #
+        # Schtop!
+        #
+        if @frozen
+          logger.debug("Frozen")
+          Thread.stop
+          logger.debug("Thawed")
+        end
+
+        yield
+
+        next if self.should_stop?
+
+        Kernel.sleep(@sleep_interval)
+      end
+
+      logger.debug("Stopped")
+    end
+
+    def should_stop?
+      @frozen or @stop
+    end
+
+    def freeze
+      logger.debug("Freezing") 
+
+      @frozen = true
+
+      20.times { Kernel.sleep 0.1 ; break if @thread.stop? }
+
+      logger.debug("Thread has not frozen!") unless @thread.stop?
+    end
+
+    def thaw
+      logger.debug("Thawing")
+
+      @frozen = false
+
+      @thread.wakeup if @thread.stop?
+    end
+
+    def start
+      logger.debug("Starting")
+      @thread = Thread.new{ self.run_thread { self.main_loop } }
+    end
+    
+    def run
+      if self.alive?
+        self.thaw
+      else
+        self.start
+      end
+    end
+
+    def alive?
+      @thread.is_a?(Thread) and @thread.alive?
+    end
+
+    def join(ok_exceptions=[])
+      begin
+        @thread.join if @thread.is_a?(Thread)
+      rescue StandardError => err
+        logger.debug "#{err.to_s} #{err.class}"
+        Kernel.raise err unless ok_exceptions.any?{|e| err.is_a?(e)}
+      end
+    end
+
+    def raise(ex)
+      @thread.raise(ex)
+    end
+
+    def restart
+      self.stop
+      self.start
+    end
+
+    def stop
+      logger.debug("Stopping")
+
+      @stop = true
+
+      10.times do 
+        break unless self.alive?
+        Kernel.sleep 1 if self.alive? 
+      end
+
+      #
+      # OK I've had enough now.
+      #
+      self.kill if self.alive?
+
+      self.join 
+    end
+
+    alias exit stop
+
+    def kill
+      logger.debug("Killing")
+      @frozen = true
+      @thread.kill
+      logger.debug("Killed")
+    end
+
+  end
+
+end
+