Dev3

.gitignore

@@ -242,7 +242,6 @@ ExportedObj/
 *.booproj
 *.svd
 
-
 # Unity3D generated meta files
 *.pidb.meta
 
@@ -370,3 +369,9 @@ captures/
 *.app
 
 .idea
+
+TextMesh Pro/
+Library/
+ProjectSettings/
+UserSettings/
+Temp/

system_Example/.gitignore

@@ -7,6 +7,7 @@
 /output
 /Assets/AssetStoreTools*
 /ProjectSettings
+*.meta
 
 # Autogenerated VS/MD solution and project files
 ExportedObj/

system_Example/Assets/system_exam/thread_exam1/thread_exam1.cs

@@ -11,47 +11,61 @@
 using UniRx.Triggers;
 using UnityEngine.UI;
 
+
 public class thread_exam1 : MonoBehaviour {
 
 	// receiving Thread
 	Thread receiveThread;
+	bool m_isRun;
 
-	// Use this for initialization
-	void Start () {
-
-		Debug.Log("start udp Thread");
-		receiveThread = new Thread(
-			new ThreadStart(ReceiveData));
-		receiveThread.IsBackground = true;
-		receiveThread.Start();
-
-
-	}
-
-	// Update is called once per frame
-	void Update () {
-
-	}
-
+	[SerializeField] Button m_btnEndThread;
 
 	// receive thread
 	private  void ReceiveData()
 	{
 		//client = new UdpClient(portLocal);
-		while (true)
+		int nCount = 1;
+		while (m_isRun)
 		{
 
 			try
 			{
 				Thread.Sleep(1000);
-				Debug.Log("tick :");
+				Debug.Log("tick :" + nCount++);
 
 			}
 			catch (Exception err)
 			{
 				print(err.ToString());
 			}
 		}
+
+		Debug.Log ("thread end");
+
 	}
 
+	// Use this for initialization
+	void Start () {
+
+		m_isRun = true;
+
+		Debug.Log("start udp Thread");
+		receiveThread = new Thread(
+			new ThreadStart(ReceiveData));
+		receiveThread.IsBackground = true;
+		receiveThread.Start();
+
+		m_btnEndThread.OnClickAsObservable ()
+			.Subscribe (_ => {
+				m_isRun = false;
+		});
+
+		Observable.OnceApplicationQuit ()
+			.Subscribe (_ => {
+				Debug.Log("OnceApplicationQuit");
+				m_isRun = false;
+			}).AddTo(this);
+	}
+
+
 }

system_Example/Assets/system_exam/thread_exam2/main.cs

@@ -0,0 +1,77 @@
+using UnityEngine;
+using System.Collections;
+
+using System;
+using System.Text;
+using System.Net;
+using System.Net.Sockets;
+using System.Threading;
+
+using UniRx;
+using UniRx.Triggers;
+using UnityEngine.UI;
+
+using LitJson;
+
+
+namespace thread_exam_2
+{
+
+	public class main : MonoBehaviour
+	{
+		bool m_isAppQuitting;
+		[SerializeField] Button m_BtnEnd;
+
+		public System.IDisposable _udpSequence;
+
+		// Use this for initialization
+		void Start ()
+		{
+			m_isAppQuitting = false;
+			_udpSequence = Observable.Create < JsonData > ( observer  => 
+				{ 
+					int nCount=1;
+
+					while  (! m_isAppQuitting ) 
+					{ 
+						Thread.Sleep(1000);
+						Debug.Log("tick ");
+						JsonData test_json = new JsonData();
+						test_json["count"] = nCount++;
+						observer . OnNext (test_json);
+					} 
+					Debug.Log("thread finish");
+					observer . OnCompleted (); 
+					return  null ; 
+				}) 
+				. SubscribeOn ( Scheduler . ThreadPool ) 
+				. Publish () 
+				. RefCount () 
+				. ObserveOnMainThread () 
+				. Subscribe ( x  => { 
+					Debug.Log ( x.ToJson() );
+				}) 
+				. AddTo ( this ); 
+
+			m_BtnEnd.onClick.AsObservable().Subscribe (_ => {
+				Debug.Log("dispose thread");
+				_udpSequence.Dispose ();
+
+			});
+
+
+			Observable.OnceApplicationQuit ().Subscribe (_ => {
+
+				Debug.Log("app quit");
+				_udpSequence.Dispose ();
+
+			}).AddTo(this);
+
+
+
+
+		}
+
+	}
+
+}