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

library / src / main / java / org / distorted / library / message / EffectMessageSender.java @ 2f40484b

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

Project

General

Profile

Distorted Android

library / src / main / java / org / distorted / library / message / EffectMessageSender.java @ 2f40484b