Project

General

Profile

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

library / src / main / java / org / distorted / library / message / EffectMessageSender.java @ 188b3dc0

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