Project

General

Profile

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

library / src / main / java / org / distorted / library / message / EffectMessageSender.java @ 43eecb4c

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 6a06a912 Leszek Koltunski
///////////////////////////////////////////////////////////////////////////////////////////////////
53
   
54
  private EffectMessageSender() 
55
    {
56 46b572b5 Leszek Koltunski
57 6a06a912 Leszek Koltunski
    }
58
59
///////////////////////////////////////////////////////////////////////////////////////////////////
60
61 ed06301f Leszek Koltunski
  public static void startSending()
62 6a06a912 Leszek Koltunski
    {
63 43eecb4c Leszek Koltunski
    synchronized(mLock)
64 6a06a912 Leszek Koltunski
      {
65 43eecb4c Leszek Koltunski
      mRunning = true;
66
67
      if( mThis==null )
68 6a06a912 Leszek Koltunski
        {
69 43eecb4c Leszek Koltunski
        mList = new Vector<>();
70
        mThis = new EffectMessageSender();
71
        mThis.start();
72 6a06a912 Leszek Koltunski
        }
73 43eecb4c Leszek Koltunski
      else mLock.notify();
74 6a06a912 Leszek Koltunski
      }
75
    }
76
77
///////////////////////////////////////////////////////////////////////////////////////////////////
78
  
79 ed06301f Leszek Koltunski
  public static void stopSending()
80 6a06a912 Leszek Koltunski
    {
81 43eecb4c Leszek Koltunski
    synchronized(mLock)
82 5fd28c26 Leszek Koltunski
      {
83 43eecb4c Leszek Koltunski
      mRunning = false;
84
      if( mThis!=null ) mLock.notify();
85 5fd28c26 Leszek Koltunski
      }
86 6a06a912 Leszek Koltunski
    }
87
  
88
///////////////////////////////////////////////////////////////////////////////////////////////////
89
  
90
  public void run()
91
    {
92
    Message tmp;  
93
     
94 5fd28c26 Leszek Koltunski
    while(mRunning)
95 6a06a912 Leszek Koltunski
      {
96 6613266b Leszek Koltunski
      while( mList.size()>0 )
97 6a06a912 Leszek Koltunski
        {
98 6613266b Leszek Koltunski
        tmp = mList.remove(0);
99 20dbec0e Leszek Koltunski
        tmp.mListener.effectFinished(tmp.mEffectID);
100 6a06a912 Leszek Koltunski
        }
101 6613266b Leszek Koltunski
102 19e77994 Leszek Koltunski
      synchronized(mLock)
103 6a06a912 Leszek Koltunski
        {
104 6613266b Leszek Koltunski
        if (!mNotify)
105 6a06a912 Leszek Koltunski
          {
106 19e77994 Leszek Koltunski
          try  { mLock.wait(); }
107
          catch(InterruptedException ignored) { }
108 6a06a912 Leszek Koltunski
          }
109 6613266b Leszek Koltunski
        mNotify = false;
110 6a06a912 Leszek Koltunski
        }
111
      }
112 5fd28c26 Leszek Koltunski
113
    mThis = null;
114 0318e7e3 Leszek Koltunski
    mList.clear();
115 6a06a912 Leszek Koltunski
    }
116
  
117
///////////////////////////////////////////////////////////////////////////////////////////////////
118
        
119 20dbec0e Leszek Koltunski
  public static void newMessage(Effect effect)
120 6a06a912 Leszek Koltunski
    {
121 20dbec0e Leszek Koltunski
    int numListeners = effect.getNumListeners();
122 6613266b Leszek Koltunski
123 20dbec0e Leszek Koltunski
    if( numListeners>0 )
124 0df17fad Leszek Koltunski
      {
125 20dbec0e Leszek Koltunski
      long id = effect.getID();
126
127
      for(int i=0; i<numListeners; i++)
128
        {
129 b7209ffe Leszek Koltunski
        EffectListener listener = effect.removeFirstListener();
130 19e77994 Leszek Koltunski
        Message msg = new Message(listener,id);
131 20dbec0e Leszek Koltunski
        mList.add(msg);
132
        }
133
134 19e77994 Leszek Koltunski
      synchronized(mLock)
135 20dbec0e Leszek Koltunski
        {
136
        mNotify = true;
137 19e77994 Leszek Koltunski
        mLock.notify();
138 20dbec0e Leszek Koltunski
        }
139 0df17fad Leszek Koltunski
      }
140 6a06a912 Leszek Koltunski
    }
141 188b3dc0 Leszek Koltunski
142
///////////////////////////////////////////////////////////////////////////////////////////////////
143
144
  public static String reportState()
145
    {
146
    return "mRunning="+mRunning+" mNotify="+mNotify+" mThis null="+(mThis==null)+" mList elements="+mList.size();
147
    }
148 6a06a912 Leszek Koltunski
  }