Project

General

Profile

Download (4.96 KB) Statistics
| Branch: | Revision:

library / src / main / java / org / distorted / library / message / EffectMessageSender.java @ 7d151b69

1 d333eb6b Leszek Koltunski
///////////////////////////////////////////////////////////////////////////////////////////////////
2
// Copyright 2016 Leszek Koltunski                                                               //
3
//                                                                                               //
4 46b572b5 Leszek Koltunski
// This file is part of Distorted.                                                               //
5 d333eb6b Leszek Koltunski
//                                                                                               //
6 46b572b5 Leszek Koltunski
// Distorted is free software: you can redistribute it and/or modify                             //
7 d333eb6b Leszek Koltunski
// it under the terms of the GNU General Public License as published by                          //
8
// the Free Software Foundation, either version 2 of the License, or                             //
9
// (at your option) any later version.                                                           //
10
//                                                                                               //
11 46b572b5 Leszek Koltunski
// Distorted is distributed in the hope that it will be useful,                                  //
12 d333eb6b Leszek Koltunski
// but WITHOUT ANY WARRANTY; without even the implied warranty of                                //
13
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the                                 //
14
// GNU General Public License for more details.                                                  //
15
//                                                                                               //
16
// You should have received a copy of the GNU General Public License                             //
17 46b572b5 Leszek Koltunski
// along with Distorted.  If not, see <http://www.gnu.org/licenses/>.                            //
18 d333eb6b Leszek Koltunski
///////////////////////////////////////////////////////////////////////////////////////////////////
19
20 ed06301f Leszek Koltunski
package org.distorted.library.message;
21 e458a4ba Leszek Koltunski
22 20dbec0e Leszek Koltunski
import org.distorted.library.effect.Effect;
23
24 6a06a912 Leszek Koltunski
import java.util.Vector;
25
26
///////////////////////////////////////////////////////////////////////////////////////////////////
27 ed06301f Leszek Koltunski
/**
28
 * Not part of public API, do not document (public only because has to be used in Meshes)
29
 *
30
 * @y.exclude
31
 */
32
public final class EffectMessageSender extends Thread
33 6a06a912 Leszek Koltunski
  {
34 19e77994 Leszek Koltunski
  private static class Message
35 6a06a912 Leszek Koltunski
    {
36
    EffectListener mListener;
37
    long mEffectID;
38 c6e1c219 Leszek Koltunski
39 20dbec0e Leszek Koltunski
    Message(EffectListener listener, long effectID)
40 6a06a912 Leszek Koltunski
      {
41 20dbec0e Leszek Koltunski
      mListener = listener;
42
      mEffectID = effectID;
43 6a06a912 Leszek Koltunski
      }
44
    }
45 19e77994 Leszek Koltunski
46
  private static final Object mLock        = new Object();
47
  private static Vector<Message> mList     = null;
48
  private static EffectMessageSender mThis = null;
49 5fd28c26 Leszek Koltunski
  private static volatile boolean mNotify  = false;
50
  private static volatile boolean mRunning = false;
51 6613266b Leszek Koltunski
52 7d151b69 Leszek Koltunski
  private static long mStartTime, mStopTime;
53
54 6a06a912 Leszek Koltunski
///////////////////////////////////////////////////////////////////////////////////////////////////
55
   
56
  private EffectMessageSender() 
57
    {
58 46b572b5 Leszek Koltunski
59 6a06a912 Leszek Koltunski
    }
60
61
///////////////////////////////////////////////////////////////////////////////////////////////////
62
63 ed06301f Leszek Koltunski
  public static void startSending()
64 6a06a912 Leszek Koltunski
    {
65 7d151b69 Leszek Koltunski
    mStartTime = System.currentTimeMillis();
66
67 43eecb4c Leszek Koltunski
    synchronized(mLock)
68 6a06a912 Leszek Koltunski
      {
69 43eecb4c Leszek Koltunski
      mRunning = true;
70
71
      if( mThis==null )
72 6a06a912 Leszek Koltunski
        {
73 43eecb4c Leszek Koltunski
        mList = new Vector<>();
74
        mThis = new EffectMessageSender();
75
        mThis.start();
76 6a06a912 Leszek Koltunski
        }
77 43eecb4c Leszek Koltunski
      else mLock.notify();
78 6a06a912 Leszek Koltunski
      }
79
    }
80
81
///////////////////////////////////////////////////////////////////////////////////////////////////
82
  
83 ed06301f Leszek Koltunski
  public static void stopSending()
84 6a06a912 Leszek Koltunski
    {
85 7d151b69 Leszek Koltunski
    mStopTime = System.currentTimeMillis();
86
87 43eecb4c Leszek Koltunski
    synchronized(mLock)
88 5fd28c26 Leszek Koltunski
      {
89 43eecb4c Leszek Koltunski
      mRunning = false;
90
      if( mThis!=null ) mLock.notify();
91 5fd28c26 Leszek Koltunski
      }
92 6a06a912 Leszek Koltunski
    }
93
  
94
///////////////////////////////////////////////////////////////////////////////////////////////////
95
  
96
  public void run()
97
    {
98
    Message tmp;  
99
     
100 5fd28c26 Leszek Koltunski
    while(mRunning)
101 6a06a912 Leszek Koltunski
      {
102 6613266b Leszek Koltunski
      while( mList.size()>0 )
103 6a06a912 Leszek Koltunski
        {
104 6613266b Leszek Koltunski
        tmp = mList.remove(0);
105 20dbec0e Leszek Koltunski
        tmp.mListener.effectFinished(tmp.mEffectID);
106 6a06a912 Leszek Koltunski
        }
107 6613266b Leszek Koltunski
108 19e77994 Leszek Koltunski
      synchronized(mLock)
109 6a06a912 Leszek Koltunski
        {
110 6613266b Leszek Koltunski
        if (!mNotify)
111 6a06a912 Leszek Koltunski
          {
112 19e77994 Leszek Koltunski
          try  { mLock.wait(); }
113
          catch(InterruptedException ignored) { }
114 6a06a912 Leszek Koltunski
          }
115 6613266b Leszek Koltunski
        mNotify = false;
116 6a06a912 Leszek Koltunski
        }
117
      }
118 5fd28c26 Leszek Koltunski
119
    mThis = null;
120 0318e7e3 Leszek Koltunski
    mList.clear();
121 6a06a912 Leszek Koltunski
    }
122
  
123
///////////////////////////////////////////////////////////////////////////////////////////////////
124
        
125 20dbec0e Leszek Koltunski
  public static void newMessage(Effect effect)
126 6a06a912 Leszek Koltunski
    {
127 20dbec0e Leszek Koltunski
    int numListeners = effect.getNumListeners();
128 6613266b Leszek Koltunski
129 20dbec0e Leszek Koltunski
    if( numListeners>0 )
130 0df17fad Leszek Koltunski
      {
131 20dbec0e Leszek Koltunski
      long id = effect.getID();
132
133
      for(int i=0; i<numListeners; i++)
134
        {
135 b7209ffe Leszek Koltunski
        EffectListener listener = effect.removeFirstListener();
136 19e77994 Leszek Koltunski
        Message msg = new Message(listener,id);
137 20dbec0e Leszek Koltunski
        mList.add(msg);
138
        }
139
140 19e77994 Leszek Koltunski
      synchronized(mLock)
141 20dbec0e Leszek Koltunski
        {
142
        mNotify = true;
143 19e77994 Leszek Koltunski
        mLock.notify();
144 20dbec0e Leszek Koltunski
        }
145 0df17fad Leszek Koltunski
      }
146 6a06a912 Leszek Koltunski
    }
147 188b3dc0 Leszek Koltunski
148
///////////////////////////////////////////////////////////////////////////////////////////////////
149
150
  public static String reportState()
151
    {
152 7d151b69 Leszek Koltunski
    return "mRunning="+mRunning+" mNotify="+mNotify+" mThis null="+(mThis==null)+
153
           " mList elements="+mList.size()+" start time="+mStartTime+" mStopTime="+mStopTime;
154 188b3dc0 Leszek Koltunski
    }
155 6a06a912 Leszek Koltunski
  }