/src/main/java/org/distorted/library/message/EffectMessageSender.java - Annotate - Distorted Android

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

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	9ef86c9f	Leszek Koltunski	import java.util.Vector;
25	6a06a912	Leszek Koltunski
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	9ef86c9f	Leszek Koltunski	private static Vector<Message> mList = null;
48	19e77994	Leszek Koltunski	private static EffectMessageSender mThis = null;
49	5fd28c26	Leszek Koltunski	private static volatile boolean mNotify = false;
50	6613266b	Leszek Koltunski
51	2f40484b	Leszek Koltunski	// debug only, to be removed later
52			private static int mNumStarts = 0;
53	7d151b69	Leszek Koltunski	private static long mStartTime, mStopTime;
54
55	6a06a912	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
56
57			private EffectMessageSender()
58			{
59	46b572b5	Leszek Koltunski
60	6a06a912	Leszek Koltunski	}
61
62			///////////////////////////////////////////////////////////////////////////////////////////////////
63
64	ed06301f	Leszek Koltunski	public static void startSending()
65	6a06a912	Leszek Koltunski	{
66	43eecb4c	Leszek Koltunski	synchronized(mLock)
67	6a06a912	Leszek Koltunski	{
68	43eecb4c	Leszek Koltunski	if( mThis==null )
69	6a06a912	Leszek Koltunski	{
70	c38f3d33	Leszek Koltunski	mStartTime = System.currentTimeMillis();
71			mNumStarts++;
72
73	9ef86c9f	Leszek Koltunski	mList = new Vector<>();
74	43eecb4c	Leszek Koltunski	mThis = new EffectMessageSender();
75			mThis.start();
76	6a06a912	Leszek Koltunski	}
77			}
78			}
79
80			///////////////////////////////////////////////////////////////////////////////////////////////////
81
82	ed06301f	Leszek Koltunski	public static void stopSending()
83	6a06a912	Leszek Koltunski	{
84	43eecb4c	Leszek Koltunski	synchronized(mLock)
85	5fd28c26	Leszek Koltunski	{
86	c337dd1c	Leszek Koltunski	if( mThis!=null )
87			{
88	c38f3d33	Leszek Koltunski	mStopTime = System.currentTimeMillis();
89			mNumStarts--;
90
91	c337dd1c	Leszek Koltunski	mThis=null;
92			mLock.notify();
93			}
94	5fd28c26	Leszek Koltunski	}
95	6a06a912	Leszek Koltunski	}
96
97			///////////////////////////////////////////////////////////////////////////////////////////////////
98
99			public void run()
100			{
101			Message tmp;
102
103	c337dd1c	Leszek Koltunski	while(mThis!=null)
104	6a06a912	Leszek Koltunski	{
105	9ef86c9f	Leszek Koltunski	while( mList.size()>0 )
106	6a06a912	Leszek Koltunski	{
107	9ef86c9f	Leszek Koltunski	tmp = mList.remove(0);
108			tmp.mListener.effectFinished(tmp.mEffectID);
109	6a06a912	Leszek Koltunski	}
110	6613266b	Leszek Koltunski
111	19e77994	Leszek Koltunski	synchronized(mLock)
112	6a06a912	Leszek Koltunski	{
113	6613266b	Leszek Koltunski	if (!mNotify)
114	6a06a912	Leszek Koltunski	{
115	19e77994	Leszek Koltunski	try { mLock.wait(); }
116			catch(InterruptedException ignored) { }
117	6a06a912	Leszek Koltunski	}
118	6613266b	Leszek Koltunski	mNotify = false;
119	6a06a912	Leszek Koltunski	}
120			}
121	5fd28c26	Leszek Koltunski
122	0318e7e3	Leszek Koltunski	mList.clear();
123	6a06a912	Leszek Koltunski	}
124
125			///////////////////////////////////////////////////////////////////////////////////////////////////
126
127	20dbec0e	Leszek Koltunski	public static void newMessage(Effect effect)
128	6a06a912	Leszek Koltunski	{
129	20dbec0e	Leszek Koltunski	int numListeners = effect.getNumListeners();
130	6613266b	Leszek Koltunski
131	20dbec0e	Leszek Koltunski	if( numListeners>0 )
132	0df17fad	Leszek Koltunski	{
133	20dbec0e	Leszek Koltunski	long id = effect.getID();
134
135	9ef86c9f	Leszek Koltunski	for(int i=0; i<numListeners; i++)
136	20dbec0e	Leszek Koltunski	{
137	9ef86c9f	Leszek Koltunski	EffectListener listener = effect.removeFirstListener();
138			Message msg = new Message(listener,id);
139			mList.add(msg);
140	20dbec0e	Leszek Koltunski	}
141
142	19e77994	Leszek Koltunski	synchronized(mLock)
143	20dbec0e	Leszek Koltunski	{
144			mNotify = true;
145	19e77994	Leszek Koltunski	mLock.notify();
146	20dbec0e	Leszek Koltunski	}
147	0df17fad	Leszek Koltunski	}
148	6a06a912	Leszek Koltunski	}
149	188b3dc0	Leszek Koltunski
150	c337dd1c	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
151
152			public static boolean isRunning()
153			{
154			return mThis!=null;
155			}
156
157			///////////////////////////////////////////////////////////////////////////////////////////////////
158
159			public static void restartThread()
160			{
161			synchronized(mLock)
162			{
163			if( mThis==null )
164			{
165	9ef86c9f	Leszek Koltunski	if( mList==null ) mList = new Vector<>();
166	c337dd1c	Leszek Koltunski	mThis = new EffectMessageSender();
167			mThis.start();
168			}
169			}
170			}
171
172	188b3dc0	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
173
174			public static String reportState()
175			{
176	c337dd1c	Leszek Koltunski	return "running "+(mThis!=null)+" notify="+mNotify+" elements="+mList.size()+
177			" start="+mStartTime+" stop="+mStopTime+" numStarts="+mNumStarts;
178	188b3dc0	Leszek Koltunski	}
179	6a06a912	Leszek Koltunski	}

Project

General

Profile

Distorted Android

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