Project

General

Profile

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

library / src / main / java / org / distorted / library / message / EffectMessageSender.java @ b7209ffe

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
  private class Message
35
    {
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
  
46
  private static Vector<Message> mList =null;
47
  private static EffectMessageSender mThis=null;
48 5fd28c26 Leszek Koltunski
  private static volatile boolean mNotify  = false;
49
  private static volatile boolean mRunning = false;
50 6613266b Leszek Koltunski
51 6a06a912 Leszek Koltunski
///////////////////////////////////////////////////////////////////////////////////////////////////
52
   
53
  private EffectMessageSender() 
54
    {
55 46b572b5 Leszek Koltunski
56 6a06a912 Leszek Koltunski
    }
57
58
///////////////////////////////////////////////////////////////////////////////////////////////////
59
60 ed06301f Leszek Koltunski
  public static void startSending()
61 6a06a912 Leszek Koltunski
    {
62 5fd28c26 Leszek Koltunski
    mRunning = true;
63
64 6a06a912 Leszek Koltunski
    if( mThis==null )
65
      {
66 c6e1c219 Leszek Koltunski
      mList = new Vector<>();
67 6a06a912 Leszek Koltunski
      mThis = new EffectMessageSender();
68
      mThis.start();
69
      }
70
    else  
71
      {  
72 9559b088 Leszek Koltunski
      synchronized(mThis)
73 6a06a912 Leszek Koltunski
        {
74
        mThis.notify();
75
        }
76
      }
77
    }
78
79
///////////////////////////////////////////////////////////////////////////////////////////////////
80
  
81 ed06301f Leszek Koltunski
  public static void stopSending()
82 6a06a912 Leszek Koltunski
    {
83 5fd28c26 Leszek Koltunski
    mRunning = false;
84 6613266b Leszek Koltunski
85 81376ddb Leszek Koltunski
    if( mThis!=null )
86 5fd28c26 Leszek Koltunski
      {
87 9559b088 Leszek Koltunski
      synchronized(mThis)
88 81376ddb Leszek Koltunski
        {
89
        mThis.notify();
90
        }
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 9559b088 Leszek Koltunski
      synchronized(mThis)
109 6a06a912 Leszek Koltunski
        {
110 6613266b Leszek Koltunski
        if (!mNotify)
111 6a06a912 Leszek Koltunski
          {
112
          try  { mThis.wait(); }
113
          catch(InterruptedException ex) { }
114
          }
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
        Message msg = mThis.new Message(listener,id);
137 20dbec0e Leszek Koltunski
        mList.add(msg);
138
        }
139
140
      synchronized(mThis)
141
        {
142
        mNotify = true;
143
        mThis.notify();
144
        }
145 0df17fad Leszek Koltunski
      }
146 6a06a912 Leszek Koltunski
    }
147
  }