Distorted Android

import org.distorted.library.message.EffectMessageSender;

import org.distorted.library.message.EffectMessageSender;

import org.distorted.library.message.EffectMessageSender;

import org.distorted.library.message.EffectMessageSender;

import org.distorted.library.message.EffectMessageSender;

import org.distorted.library.message.EffectMessageSender;

///////////////////////////////////////////////////////////////////////////////////////////////////

// Copyright 2016 Leszek Koltunski                                                               //

//                                                                                               //

// This file is part of Distorted.                                                               //

//                                                                                               //

// Distorted is free software: you can redistribute it and/or modify                             //

// it under the terms of the GNU General Public License as published by                          //

// the Free Software Foundation, either version 2 of the License, or                             //

// (at your option) any later version.                                                           //

//                                                                                               //

// Distorted is distributed in the hope that it will be useful,                                  //

// but WITHOUT ANY WARRANTY; without even the implied warranty of                                //

// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the                                 //

// GNU General Public License for more details.                                                  //

//                                                                                               //

// You should have received a copy of the GNU General Public License                             //

// along with Distorted.  If not, see <http://www.gnu.org/licenses/>.                            //

///////////////////////////////////////////////////////////////////////////////////////////////////

package org.distorted.library.message;

import java.util.Vector;

///////////////////////////////////////////////////////////////////////////////////////////////////

/**

 * Not part of public API, do not document (public only because has to be used in Meshes)

 *

 * @y.exclude

 */

public final class EffectMessageSender extends Thread

  {

  private class Message

    {

    EffectListener mListener;

    EffectMessage mMessage;

    long mEffectID;

    long mObjectID;

    Message(EffectListener l, EffectMessage m, long effID, long objID)

      {

      mListener = l;

      mMessage  = m;

      mEffectID = effID;

      mObjectID = objID;

      }

    }

  private static Vector<Message> mList =null;

  private static EffectMessageSender mThis=null;

  private static volatile boolean mNotify  = false;

  private static volatile boolean mRunning = false;

///////////////////////////////////////////////////////////////////////////////////////////////////

  private EffectMessageSender() 

    {

    }

///////////////////////////////////////////////////////////////////////////////////////////////////

  public static void startSending()

    {

    mRunning = true;

    if( mThis==null )

      {

      mList = new Vector<>();

      mThis = new EffectMessageSender();

      mThis.start();

      }

    else  

      {  

      synchronized(mThis)

        {

        mThis.notify();

        }

      }

    }

///////////////////////////////////////////////////////////////////////////////////////////////////

  public static void stopSending()

    {

    mRunning = false;

    if( mThis!=null )

      {

      synchronized(mThis)

        {

        mThis.notify();

        }

      }

    }

///////////////////////////////////////////////////////////////////////////////////////////////////

  public void run()

    {

    Message tmp;  

    while(mRunning)

      {

      //android.util.Log.i("SENDER", "sender thread running...");

      while( mList.size()>0 )

        {

        tmp = mList.remove(0);

        tmp.mListener.effectMessage(tmp.mMessage, tmp.mEffectID, tmp.mObjectID);

        }

      synchronized(mThis)

        {

        if (!mNotify)

          {

          try  { mThis.wait(); }

          catch(InterruptedException ex) { }

          }

        mNotify = false;

        }

      }

    mThis = null;

    mList.clear();

    //android.util.Log.i("SENDER", "sender thread finished...");

    }

///////////////////////////////////////////////////////////////////////////////////////////////////

  public static void newMessage(EffectListener l, EffectMessage m, long effID, long objID)

    {

    Message msg = mThis.new Message(l,m,effID,objID);

    mList.add(msg);

    synchronized(mThis)

      {

      mNotify = true;

      mThis.notify();

      }

    }

  }