Project

General

Profile

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

library / src / main / java / org / distorted / library / main / EffectMessageSender.java @ c41d046c

1 d333eb6b Leszek Koltunski
///////////////////////////////////////////////////////////////////////////////////////////////////
2
// Copyright 2016 Leszek Koltunski                                                               //
3
//                                                                                               //
4
// This file is part of Distorted.                                                               //
5
//                                                                                               //
6
// Distorted is free software: you can redistribute it and/or modify                             //
7
// 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
// Distorted is distributed in the hope that it will be useful,                                  //
12
// 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
// along with Distorted.  If not, see <http://www.gnu.org/licenses/>.                            //
18
///////////////////////////////////////////////////////////////////////////////////////////////////
19
20 fe82a979 Leszek Koltunski
package org.distorted.library.main;
21 6a06a912 Leszek Koltunski
22 e458a4ba Leszek Koltunski
import org.distorted.library.message.EffectListener;
23
import org.distorted.library.message.EffectMessage;
24
25 6a06a912 Leszek Koltunski
import java.util.Vector;
26
27
///////////////////////////////////////////////////////////////////////////////////////////////////
28
29
final class EffectMessageSender extends Thread
30
  {
31
  private class Message
32
    {
33
    EffectListener mListener;
34
    EffectMessage mMessage;
35
    long mEffectID;
36 15aa7d94 Leszek Koltunski
    long mObjectID;
37 c6e1c219 Leszek Koltunski
38 15aa7d94 Leszek Koltunski
    Message(EffectListener l, EffectMessage m, long effID, long objID)
39 6a06a912 Leszek Koltunski
      {
40 15aa7d94 Leszek Koltunski
      mListener = l;
41
      mMessage  = m;
42
      mEffectID = effID;
43
      mObjectID = objID;
44 6a06a912 Leszek Koltunski
      }
45
    }
46
  
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
    }
57
58
///////////////////////////////////////////////////////////////////////////////////////////////////
59
60
  static void startSending()
61
    {
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
      synchronized(mThis)
73
        {
74
        mThis.notify();
75
        }
76
      }
77
    }
78
79
///////////////////////////////////////////////////////////////////////////////////////////////////
80
  
81
  static void stopSending()
82
    {
83 5fd28c26 Leszek Koltunski
    mRunning = false;
84 6613266b Leszek Koltunski
85 81376ddb Leszek Koltunski
    if( mThis!=null )
86 5fd28c26 Leszek Koltunski
      {
87 81376ddb Leszek Koltunski
      synchronized(mThis)
88
        {
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 5fd28c26 Leszek Koltunski
      //android.util.Log.i("SENDER", "sender thread running...");
103 6613266b Leszek Koltunski
104
      while( mList.size()>0 )
105 6a06a912 Leszek Koltunski
        {
106 6613266b Leszek Koltunski
        tmp = mList.remove(0);
107 15aa7d94 Leszek Koltunski
        tmp.mListener.effectMessage(tmp.mMessage, tmp.mEffectID, tmp.mObjectID);
108 6a06a912 Leszek Koltunski
        }
109 6613266b Leszek Koltunski
110
      synchronized(mThis)
111 6a06a912 Leszek Koltunski
        {
112 6613266b Leszek Koltunski
        if (!mNotify)
113 6a06a912 Leszek Koltunski
          {
114
          try  { mThis.wait(); }
115
          catch(InterruptedException ex) { }
116
          }
117 6613266b Leszek Koltunski
        mNotify = false;
118 6a06a912 Leszek Koltunski
        }
119
      }
120 5fd28c26 Leszek Koltunski
121
    mThis = null;
122 0318e7e3 Leszek Koltunski
    mList.clear();
123 5fd28c26 Leszek Koltunski
124
    //android.util.Log.i("SENDER", "sender thread finished...");
125 6a06a912 Leszek Koltunski
    }
126
  
127
///////////////////////////////////////////////////////////////////////////////////////////////////
128
        
129 15aa7d94 Leszek Koltunski
  static void newMessage(EffectListener l, EffectMessage m, long effID, long objID)
130 6a06a912 Leszek Koltunski
    {
131 15aa7d94 Leszek Koltunski
    Message msg = mThis.new Message(l,m,effID,objID);
132 6613266b Leszek Koltunski
    mList.add(msg);
133
134
    synchronized(mThis)
135 0df17fad Leszek Koltunski
      {
136 6613266b Leszek Koltunski
      mNotify = true;
137
      mThis.notify();
138 0df17fad Leszek Koltunski
      }
139 6a06a912 Leszek Koltunski
    }
140
  }