Также возможен режим
работы программы без распараллеливания.
Листинг 1. Program.cs.
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Diagnostics;
namespace ConsoleApplication1
{
class Program
{
public static int hhhhhhhh=0;
static int ProcessorCount;
static void Main(string[]
args)
{
//количество процессоров
ProcessorCount =
Environment.ProcessorCount;
//ProcessorCount = 2;
//список,
содержащий части массива
Console.WriteLine("1 - режим без
распараллеливания. 2 - режим с распаралливанием. Сделайте выбор:");
String s = Console.ReadLine();
Random rnd1 = new Random();
// 2147483647
int n = 150000000;
Console.WriteLine("Генерация
массива из {0} записей типа integer", n);
int[] b = new int[n];
GC.Collect();
int max = 100;
for (int i = 0; i < b.Length;
i++)
b[i] = rnd1.Next(0, max);
Console.WriteLine("Запись в файл");
using (System.IO.StreamWriter file =
new System.IO.StreamWriter(@"2.txt"))
foreach (int t in b)
file.Write(t.ToString() +
" ");
int rrrr = int.Parse(s);
massiv y = new massiv(b, 0, n-1,
null);
if ((rrrr ==
1)||(ProcessorCount == 1))
{
Console.WriteLine("Выполнение сортировки");
Stopwatch sw = null;
sw =
System.Diagnostics.Stopwatch.StartNew();
qSort1(y);
sw.Stop();
var elapsed = sw.ElapsedMilliseconds;
Console.WriteLine("Затраченное время: {0}", elapsed);
}
else
{
parall(b, n);
}
Console.WriteLine("Запись в
файл");
using (System.IO.StreamWriter file
= new System.IO.StreamWriter(@"3.txt"))
foreach (int t in b)
file.Write(t.ToString() +
" ");
Console.WriteLine("Нажмите
любую клавишу для завершения");
Console.ReadKey();
}
static void parall(int[] b,
int n)
{
List<massiv> B = new
List<massiv>();
Console.WriteLine("Разделение по
массивам");
//ThreadPool.QueueUserWorkItem(new
WaitCallback(qSort1), new massiv(b, 0, n));
qSortbegin(b, 0, n - 1, 0, B);
Stopwatch sw = null;
var threads = new
List<Thread>();
ManualResetEvent[] handles = new
ManualResetEvent[B.Count];
for (int h = 0; h < B.Count;
h++)
{
massiv y = new massiv(new int[B[h].high -
B[h].low + 1], 0, B[h].high - B[h].low, null);
for (int i = B[h].low; i <
B[h].high + 1; i++)
y.B[i - B[h].low] =
B[h].B[i];
B[h] = y;
//ThreadPool.QueueUserWorkItem(new
WaitCallback(qSort1), B[h]);
//threads.Add(thread);
Console.WriteLine("B={0}", B[h].high - B[h].low + 1);
}
Console.WriteLine("Выполнение
сортировки");
sw =
System.Diagnostics.Stopwatch.StartNew();
for(int h = 0; h < B.Count; h++)
{
massiv bbbbb = B[h];
/*var thread = new Thread(()
=>
{
qSort1(bbbbb);
/*
if (threads.All(t => t.ThreadState ==
System.Threading.ThreadState.Stopped))
{
sw.Stop();
var elapsed =
sw.Elapsed;
}
});*/
Thread t = new Thread(qqsort);
handles[h] = new
ManualResetEvent(false);
bbbbb.handl = handles[h];
t.Start(bbbbb);
//threads.Add(thread);
}
WaitHandle.WaitAll(handles);
sw.Stop();
String elapsed =
sw.ElapsedMilliseconds.ToString();
// var action = new Action(() =>
//
{
//Thread.Sleep(50000);
Console.WriteLine("Затраченное время: {0}", elapsed);
Console.WriteLine("Сбор в один массив");
int k = 0;
for (int h = 0; h < B.Count;
h++)
{
for (int i = 0; i <
B[h].B.Length; i++)
{
b[k] =
B[h].B[i];
k++;
}
}
//
});
/*var thread1 = new Thread(() =>
{
qSort1(B[0]);
if (threads.All(t => t.ThreadState
== System.Threading.ThreadState.Stopped))
{
sw.Stop();
var elapsed = sw.Elapsed;
action();
}
});
threads.Add(thread1);
var thread2 = new Thread(() =>
{
qSort1(B[1]);
if (threads.All(t =>
t.ThreadState == System.Threading.ThreadState.Stopped))
{
sw.Stop();
var elapsed = sw.Elapsed;
action();
}
});
threads.Add(thread2);
var thread3 = new Thread(() =>
{
qSort1(B[2]);
if (threads.All(t =>
t.ThreadState == System.Threading.ThreadState.Stopped))
{
sw.Stop();
var elapsed = sw.Elapsed;
action();
}
});
threads.Add(thread3);
var thread4 = new Thread(() =>
{
qSort1(B[3]);
if (threads.All(t =>
t.ThreadState == System.Threading.ThreadState.Stopped))
{
sw.Stop();
var elapsed = sw.Elapsed;
action();
}
});
threads.Add(thread4);
*/
/* foreach (var thread in threads)
{
thread.Start();
}*/
//thread1.Start();
B.Clear();
threads.Clear();
}
public struct massiv
{
public int[] B;
public int low;
public int high;
public ManualResetEvent handl;
public massiv(int[] _B, int _low,
int _high, ManualResetEvent _handl)
{
B = _B;
low = _low;
high = _high;
handl = _handl;
}
};
static int medial(int[] b, int low, int
high)
{
int medial1;
decimal s = 0;
for (int i = low; i < high+1;
i++)
{
s = s + (decimal)b[i];
}
medial1 = (int) (s / (high - low));
int find = 0;
int l = Math.Abs(b[low] - medial1);
for (int i = low+1; i < high;
i++)
{
if(Math.Abs(b[i]-medial1) <
l)
{
l = Math.Abs(b[i] -
medial1);
find = i;
}
}
return find;
}
static void qSortbegin(int[] A, int
low, int high, int k, List<massiv> B)
{
k++;
//int max = 100;
int i = low;
int j = high;
int n = medial(A, low, high);
int x = A[n];
do
{
while (A[i] < x) ++i;
while (A[j] > x) --j;
if (i <= j)
{
int temp = A[i];
A[i] = A[j];
A[j] = temp;
i++; j--;
}
} while (i <= j);
//int A1 = A.ToList().FindIndex(q
=> q == x);
//int A1 = j;
if (k * 2 == ProcessorCount)
{
if (low < j)
B.Add(new massiv(A, low, j,
null));
if (i < high)
B.Add(new massiv(A, j+1,
high, null));
}
else
{
if (low < j) qSortbegin(A,
low, j, k, B);
if (i < high) qSortbegin(A,
j+1, high, k, B);
}
}
static void qSort1(massiv m)
{
int[] A = m.B;
int i = m.low;
int j = m.high;
massiv m1 = m;
int x = A[(m.low + m.high) / 2];
do
{
while (A[i] < x) ++i;
while (A[j] > x) --j;
if (i <= j)
{
int temp = A[i];
A[i] = A[j];
A[j] = temp;
i++; j--;
}
} while (i <= j);
if (m1.low < j)
{
m = m1;
m.B = A; m.high = j;
qSort1(m);
}
if (i < m1.high)
{
m = m1;
m.B = A; m.low = i;
qSort1(m);
}
hhhhhhhh++;
}
static void qqsort(Object state)
{
massiv m = (massiv)state;
qSort1(m);
m.handl.Set();
}
}
}
После чего я приклеил плату с аналогом Ардуинки:
Поставил аккумы:
А теперь заливаем самую простую тестовую прогу (машинка будет ехать прямо и мигать диодом).
Далее я хочу сделать следующее - подружить Drawbot с Matlab'ом, чтобы он умел рисовать любые функции. Дружить Ардуинку и Матлаб я знаю как, теперь будем писать софт для нашего робота-художника )))
