Просмтор этого файла доступен только зарегистрированным пользователям. Но у нас супер быстрая регистрация: достаточно только электронной почты!

Текст из файла (страница 2)

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-диаграмма

Диаграмма классов:

Диаграмма последовательности

Литература

1. http://en.wikipedia.org/wiki/Scheduler_pattern

2. http://ru.wikipedia.org/wiki/Scheduler

Thread pool/Пул потоков

Категория: Шаблоны параллельного программирования

Описание

Пул потоков – это набор определенного количества потоков, которые создаются и уничтожаются димнамически в зависимости от нагрузки на приложение.

Уместность применения

Шаблон следует применять, если требуется выполнять большое количество заданий.

Преимущества, достигаемые при применении шаблона

Позволяет избежать накладных расходов связанных с созданием, уничтожением, переключением между потоками.

Недостатки шаблона

Поскольку шаблон имеет дело с потоками, то программу становаится сложно отлаживать.

Детали реализации

Классы

public sealed class Pool : IDisposable

{

LinkedList _workers;

LinkedList _tasks = new 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 randomizer = (index =>

{

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-диаграмма

Диаграмма классов:

Диаграмма последовательности

Литература

1. http://en.wikipedia.org/wiki/Thread_pool_pattern

2. http://stackoverflow.com/questions/435668/code-for-a-simple-thread-pool-in-c-sharp

3. http://rajiv-mayani.blogspot.ru/2009/02/thread-pools.html

Характеристики

Список файлов лабораторной работы