MapReduce is a programming model and an associated implementation for processing and generating big data sets with a parallel, distributed algorithm on a cluster.
「流」是一連串從I/O設備讀寫的字符（Byte）。
<themotherfuckerextremelongpropertyname> 1 </themotherfuckerextremelongpropertyname>
需要使用者互動的軟體必須儘快回應使用者的活動，以便提供豐富的使用者經驗。不過，同時它也必須執行需要的計算以儘快提供使用者資料。在個人目前的工作領域，使用者體驗並非放在第一(甚至是最後一名)，大部分時間都花在Coding工作處理常式（Routines），主要實現概念為狀態機(State-Machine)與多工處理(Multi-Task)，在Main Thread執行
class Program
{
static void Main(string[] args)
{
int state = 0;
Action __delegate = null;
Task __task = null;
IAsyncResult handle = null;
ConcurrentQueue exchange = new ConcurrentQueue();
int outValue = 0;
//the main state machine
Program.method();
while (state != 500)
{
switch (state)
{
case 0:
// use Task
__task = new Task(new Action(Program.method));
__task.Start();
state +=10;
break;
case 10:
// wait until task done
if (__task.IsCompleted)
state +=10;
break;
case 20:
// use thread pool
ThreadPool.QueueUserWorkItem((object foo)=>{
Program.method();
exchange.Enqueue(0); // enqueue some meaningfll result
},null);
state+=10;
break;
case 30:
//wait until method had been scheduled and executed
if (exchange.TryDequeue(out outValue))
state +=10;
break;
case 40:
// use delegate/IAsyncResult
__delegate = new Action(method);
handle = __delegate.BeginInvoke((IAsyncResult ar)=>
{
method();
__delegate.EndInvoke(ar); // you had to call this to release ar
},null);
break;
case 50:
// wait until method had been executed
if (handle.IsCompleted)
state = 500;
break;
default:
break;
}
Thread.Sleep(0);// yield to other thread to run
}//while
}
static void method()
{
//reflect the current thread
Console.WriteLine(System.Threading.Thread.CurrentThread.ManagedThreadId.ToString());
}
}
String __input = "Model:M1 Coordinates: X1.62 Y1.01 X9.53 Y2.3 X4.94 Y2.1 X8.55 Y3.15 X2.56 Y1.25 X5.57 Y2.72"; String __patternUnnamed = "Model:[\\\\w]+[\\\\s]+Coordinates:[\\\\s]+(X([-+]?[0-9]*\\\\.?[0-9]+)[\\\\s]*Y([-+]?[0-9]*\\\\.?[0-9]+)[\\\\s]*)+"; List若模式字串裡（）太多，或是覺得用INDEX標定群組可讀性太差，此時可以套入具名群組（Named Group）的概念，把（）所圈住的Symbol具名化：__coords = new List (); Match __matchUnnamed = Regex.Match(__input,__patternUnnamed); //----------------------------------- // Unnamed //----------------------------------- __coords.Clear(); for (int i = 0; i < __matchUnnamed.Groups[1].Captures.Count;i++) { // use X,Y group restore each coordinates float[] eachCoord = new float[]{0,0}; eachCoord[0] = float.Parse(__matchUnnamed.Groups[2].Captures[i].Value); eachCoord[1] = float.Parse(__matchUnnamed.Groups[3].Captures[i].Value); __coords.Add(eachCoord); } //check all coordinates Console.WriteLine(\"Unnamed\"); foreach (float[] item in __coords) { Console.WriteLine(String.Format(\"{0},{1}\", item[0], item[1])); }
String __patternNamed = "Model:[\\\\w]+[\\\\s]+Coordinates:[\\\\s]+(?X(? [-+]?[0-9]*\\\\.?[0-9]+)[\\\\s]*Y(? [-+]?[0-9]*\\\\.?[0-9]+)[\\\\s]*)+"; Match __matchNamed = Regex.Match(__input,__patternNamed); //----------------------------------- // Named //----------------------------------- //now we get the \"coord\" group __coords.Clear(); for (int i = 0; i < __matchNamed.Groups[\"coord\"].Captures.Count; i++) { // use X,Y group restore each coordinates float[] eachCoord = new float[]{0,0}; eachCoord[0] = float.Parse(__matchNamed.Groups[\"X\"].Captures[i].Value); eachCoord[1] = float.Parse(__matchNamed.Groups[\"Y\"].Captures[i].Value); __coords.Add(eachCoord); }
class utilities
{
/// <summary>
/// Used to store key-serializer
/// </summary>
/// <returns></returns>
private static Hashtable __dictionary = new Hashtable();
/// <summary>
/// Generate key according to contents of type list
/// </summary>
/// <param name="typeList"></param>
/// <returns></returns>
protected static int generateKey(List<Type> typeList)
{
//hash code summarize
return typeList.Sum(__type => __type.GetHashCode());
}
/// <summary>
/// Always fetch serializer from this function
/// (Never allocate by yourself)
/// </summary>
/// <param name="mainType"></param>
/// <param name="extraTypes"></param>
/// <returns></returns>
public static XmlSerializer getSerializer(Type mainType,Type[] extraTypes){
//merge the list
List<Type> __typeList = new List<Type>();
__typeList.Add(mainType);
__typeList.AddRange(extraTypes);
var key = generateKey(__typeList);
if (__dictionary.ContainsKey(key))
{
// this kind of serializer had been cached/used before ,
// get the cached serializer
return (XmlSerializer)__dictionary[key];
}
else
{
// never been used , need to create a new one and push into cache
XmlSerializer __serializer = new XmlSerializer(mainType,extraTypes);
__dictionary.Add(key,__serializer);
return __serializer;
}
}//getserializer
}//utilities
<project sdk="Microsoft.NET.Sdk">
<propertygroup>
<outputtype>Exe</outputtype>
<targetframework>netcoreapp1.1</targetframework>
</propertygroup>
<itemgroup>
<packagereference include="System.Collections" version="4.3.0">
<packagereference include="System.Collections.NonGeneric" version="4.3.0">
<packagereference include="System.Runtime.Extensions" version="4.3.0">
<packagereference include="System.Xml.XmlSerializer" version="4.3.0">
</packagereference></packagereference></packagereference></packagereference></itemgroup>
</project>