ПКРПСиБД LAB5 Машеров Д.Е. (Лабораторная работа 5), страница 2
Описание файла
Файл "ПКРПСиБД LAB5 Машеров Д.Е." внутри архива находится в папке "Лабораторная работа 5". Документ из архива "Лабораторная работа 5", который расположен в категории "". Всё это находится в предмете "распределённые ис и базы данных" из 9 семестр (1 семестр магистратуры), которые можно найти в файловом архиве НИУ «МЭИ» . Не смотря на прямую связь этого архива с НИУ «МЭИ» , его также можно найти и в других разделах. Архив можно найти в разделе "лабораторные работы", в предмете "распределённые ис и базы данных" в общих файлах.
Онлайн просмотр документа "ПКРПСиБД LAB5 Машеров Д.Е."
Текст 2 страницы из документа "ПКРПСиБД LAB5 Машеров Д.Е."
interface IOrdering
{
Boolean ScheduleBefore(IOrdering s);
}
class Transaction : IOrdering
{
private static DateTime mTime = DateTime.Now;
private DateTime time;
public DateTime Time { get { return time; } }
private int chng;
public int Chng
{
get { return chng; }
}
public Transaction(int chng)
{
mTime = mTime.AddSeconds(1);
time = mTime;
this.chng = chng;
}
public void Do(int id)
{
Console.WriteLine(String.Format(@"Transaction #{0}: Start : {1} : Balance change: {2} roubles", id, time, chng));
Thread.Sleep(1000);
Console.WriteLine(String.Format(@"Transaction #{0}: Finish : {1} : Balance change: {2} roubles", id, time, chng));
}
public Boolean ScheduleBefore(IOrdering s)
{
if (s is Transaction)
{
var otherTransaction = (Transaction)s;
return (this.Time < otherTransaction.Time);
}
return false;
}
}
Программа:
static BankAccount bankAccount;
static void Thread1()
{
var msg1 = new Transaction(10);
var msg2 = new Transaction(15);
var msg3 = new Transaction(112);
bankAccount.Handle(msg1);
bankAccount.Handle(msg2);
bankAccount.Handle(msg3);
}
static void Thread2()
{
var msg4 = new Transaction(50);
var msg5 = new Transaction(100);
bankAccount.Handle(msg4);
bankAccount.Handle(msg5);
}
static void Thread3()
{
var msg6 = new Transaction(-80);
var msg7 = new Transaction(20);
bankAccount.Handle(msg6);
bankAccount.Handle(msg7);
}
static void Main(string[] args)
{
bankAccount = new BankAccount();
new Thread(Thread1).Start();
new Thread(Thread2).Start();
//new Thread(Thread3).Start();
Console.ReadKey();
}
UML-диаграмма
Диаграмма классов:
Диаграмма последовательности
Литература
-
http://en.wikipedia.org/wiki/Scheduler_pattern
-
http://ru.wikipedia.org/wiki/Scheduler
Thread pool/Пул потоков
Категория: Шаблоны параллельного программирования
Описание
Пул потоков – это набор определенного количества потоков, которые создаются и уничтожаются димнамически в зависимости от нагрузки на приложение.
Уместность применения
Шаблон следует применять, если требуется выполнять большое количество заданий.
Преимущества, достигаемые при применении шаблона
Позволяет избежать накладных расходов связанных с созданием, уничтожением, переключением между потоками.
Недостатки шаблона
Поскольку шаблон имеет дело с потоками, то программу становаится сложно отлаживать.
Детали реализации
Классы
public sealed class Pool : IDisposable
{
LinkedList
LinkedList
bool _disallowAdd;
bool _disposed;
public Pool(int size)
{
this._workers = new LinkedList
for (var i = 0; i < size; ++i)
{
var worker = new Thread(this.Worker) { Name = string.Concat("Worker ", i) };
worker.Start();
this._workers.AddLast(worker);
}
}
public void Dispose()
{
var waitForThreads = false;
lock (this._tasks)
{
if (!this._disposed)
{
GC.SuppressFinalize(this);
this._disallowAdd = true;
while (this._tasks.Count > 0)
{
Monitor.Wait(this._tasks);
}
this._disposed = true;
Monitor.PulseAll(this._tasks);
waitForThreads = true;
}
}
if (waitForThreads)
{
foreach (var worker in this._workers)
{
worker.Join();
}
}
}
public void QueueTask(Action task)
{
lock (this._tasks)
{
if (this._disallowAdd) { throw new InvalidOperationException("This Pool instance is in the process of being disposed, can't add anymore"); }
if (this._disposed) { throw new ObjectDisposedException("This Pool instance has already been disposed"); }
this._tasks.AddLast(task);
Monitor.PulseAll(this._tasks);
}
}
private void Worker()
{
Action task = null;
while (true)
{
lock (this._tasks)
{
while (true)
{
if (this._disposed)
{
return;
}
if (null != this._workers.First && object.ReferenceEquals(Thread.CurrentThread, this._workers.First.Value) && this._tasks.Count > 0)
{
task = this._tasks.First.Value;
this._tasks.RemoveFirst();
this._workers.RemoveFirst();
Monitor.PulseAll(this._tasks);
break;
}
Monitor.Wait(this._tasks);
}
}
task();
this._workers.AddLast(Thread.CurrentThread);
task = null;
}
}
}
Программа:
static void Main(string[] args)
{
using (var pool = new Pool(5))
{
var random = new Random();
Action
{
Console.WriteLine("{0}: Working on index {1}", Thread.CurrentThread.Name, index);
Thread.Sleep(random.Next(20, 400));
Console.WriteLine("{0}: Ending {1}", Thread.CurrentThread.Name, index);
});
for (var i = 0; i < 40; ++i)
{
var i1 = i;
pool.QueueTask(() => randomizer(i1));
}
}
}
UML-диаграмма
Диаграмма классов:
Диаграмма последовательности
Литература
-
http://en.wikipedia.org/wiki/Thread_pool_pattern
-
http://stackoverflow.com/questions/435668/code-for-a-simple-thread-pool-in-c-sharp
-
http://rajiv-mayani.blogspot.ru/2009/02/thread-pools.html
