forked from v.moiseev/distributed-computing
Compare commits
2 Commits
mikhailov-
...
mikhailov-
| Author | SHA1 | Date | |
|---|---|---|---|
| e1fa178b64 | |||
| 96026e67a9 |
@@ -1,3 +1,5 @@
|
||||
var/result/
|
||||
|
||||
## Ignore Visual Studio temporary files, build results, and
|
||||
## files generated by popular Visual Studio add-ons.
|
||||
##
|
||||
15
tasks/mikhailov-ys/lab_4/Main/Consumer1/Consumer1.csproj
Normal file
15
tasks/mikhailov-ys/lab_4/Main/Consumer1/Consumer1.csproj
Normal file
@@ -0,0 +1,15 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<OutputType>Exe</OutputType>
|
||||
<TargetFramework>net6.0</TargetFramework>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<Nullable>enable</Nullable>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="RabbitMQ" Version="3.6.2" />
|
||||
<PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
31
tasks/mikhailov-ys/lab_4/Main/Consumer1/Program.cs
Normal file
31
tasks/mikhailov-ys/lab_4/Main/Consumer1/Program.cs
Normal file
@@ -0,0 +1,31 @@
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
using RabbitMQ.Client.Events;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
channel.QueueDeclare(queue: "accepted");
|
||||
channel.QueueBind(queue: "accepted",
|
||||
exchange: "report",
|
||||
routingKey: string.Empty);
|
||||
|
||||
Console.WriteLine(" [*] Waiting for messages.");
|
||||
|
||||
var consumer = new EventingBasicConsumer(channel);
|
||||
consumer.Received += async (model, ea) =>
|
||||
{
|
||||
byte[] body = ea.Body.ToArray();
|
||||
var message = Encoding.UTF8.GetString(body);
|
||||
|
||||
string outputText = $"Заявление принято к обработке {message}";
|
||||
Console.WriteLine($" [x] Done. {outputText}");
|
||||
channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
|
||||
};
|
||||
channel.BasicConsume(queue: "accepted",
|
||||
autoAck: false,
|
||||
consumer: consumer);
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
15
tasks/mikhailov-ys/lab_4/Main/Consumer2/Consumer2.csproj
Normal file
15
tasks/mikhailov-ys/lab_4/Main/Consumer2/Consumer2.csproj
Normal file
@@ -0,0 +1,15 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<OutputType>Exe</OutputType>
|
||||
<TargetFramework>net6.0</TargetFramework>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<Nullable>enable</Nullable>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="RabbitMQ" Version="3.6.2" />
|
||||
<PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
37
tasks/mikhailov-ys/lab_4/Main/Consumer2/Program.cs
Normal file
37
tasks/mikhailov-ys/lab_4/Main/Consumer2/Program.cs
Normal file
@@ -0,0 +1,37 @@
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
using RabbitMQ.Client.Events;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
Random rand = new Random();
|
||||
string queueName = $"denied{rand.Next()}";
|
||||
|
||||
channel.QueueDeclare(queue: queueName);
|
||||
channel.QueueBind(queue: queueName,
|
||||
exchange: "report",
|
||||
routingKey: string.Empty);
|
||||
|
||||
Console.WriteLine(" [*] Waiting for messages.");
|
||||
|
||||
var consumer = new EventingBasicConsumer(channel);
|
||||
consumer.Received += async (model, ea) =>
|
||||
{
|
||||
byte[] body = ea.Body.ToArray();
|
||||
var message = Encoding.UTF8.GetString(body);
|
||||
|
||||
int waitTime = rand.Next(20, 90);
|
||||
Thread.Sleep(waitTime * 100);
|
||||
|
||||
string outputText = $"Заявление обработано {message} за {waitTime} минут";
|
||||
Console.WriteLine($" [x] Done. {outputText}");
|
||||
channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
|
||||
};
|
||||
channel.BasicConsume(queue: queueName,
|
||||
autoAck: false,
|
||||
consumer: consumer);
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
30
tasks/mikhailov-ys/lab_4/Main/Publisher/Program.cs
Normal file
30
tasks/mikhailov-ys/lab_4/Main/Publisher/Program.cs
Normal file
@@ -0,0 +1,30 @@
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
channel.ExchangeDeclare(exchange: "report", type: ExchangeType.Fanout);
|
||||
Random rand = new Random();
|
||||
foreach (var item in Enumerable.Range(0, 1000))
|
||||
{
|
||||
var message = rand.Next().ToString();
|
||||
|
||||
var body = Encoding.UTF8.GetBytes(message);
|
||||
channel.BasicPublish(exchange: "report",
|
||||
routingKey: string.Empty,
|
||||
basicProperties: null,
|
||||
body: body);
|
||||
|
||||
Console.WriteLine($" [x] Поступило заявление {message}");
|
||||
await Task.Delay(500);
|
||||
}
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
|
||||
static string GetMessage(string[] args)
|
||||
{
|
||||
return ((args.Length > 0) ? string.Join(" ", args) : "info: Принято!");
|
||||
}
|
||||
15
tasks/mikhailov-ys/lab_4/Main/Publisher/Publisher.csproj
Normal file
15
tasks/mikhailov-ys/lab_4/Main/Publisher/Publisher.csproj
Normal file
@@ -0,0 +1,15 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<OutputType>Exe</OutputType>
|
||||
<TargetFramework>net6.0</TargetFramework>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<Nullable>enable</Nullable>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="RabbitMQ" Version="3.6.2" />
|
||||
<PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
149
tasks/mikhailov-ys/lab_4/README.md
Normal file
149
tasks/mikhailov-ys/lab_4/README.md
Normal file
@@ -0,0 +1,149 @@
|
||||
# Отчёт по лабораторной работе №4
|
||||
|
||||
Выполнил: студент гр. ИСЭбд-41 Михайлов Ю.С.
|
||||
|
||||
## Прохождение туториалов
|
||||
|
||||
Установил RabbitMQ, Erlang и зашел в брокер под гостем по адресу http://localhost:15672/#/
|
||||
|
||||
Туториал 1:
|
||||
|
||||
|
||||
|
||||
|
||||
Туториал 2:
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
Туториал 3:
|
||||
|
||||
|
||||
|
||||
|
||||
## Разработка демонстрационных приложений
|
||||
|
||||
Предметная область - оформление заявлений на стипендию в университете. Разработано три приложения согласно предметной области.
|
||||
|
||||
1. Publisher:
|
||||
```
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
channel.ExchangeDeclare(exchange: "report", type: ExchangeType.Fanout);
|
||||
Random rand = new Random();
|
||||
foreach (var item in Enumerable.Range(0, 1000))
|
||||
{
|
||||
var message = rand.Next().ToString();
|
||||
|
||||
var body = Encoding.UTF8.GetBytes(message);
|
||||
channel.BasicPublish(exchange: "report",
|
||||
routingKey: string.Empty,
|
||||
basicProperties: null,
|
||||
body: body);
|
||||
|
||||
Console.WriteLine($" [x] Поступило заявление {message}");
|
||||
await Task.Delay(500);
|
||||
}
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
|
||||
static string GetMessage(string[] args)
|
||||
{
|
||||
return ((args.Length > 0) ? string.Join(" ", args) : "info: Принято!");
|
||||
}
|
||||
```
|
||||
2. Consumer 1:
|
||||
```
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
using RabbitMQ.Client.Events;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
channel.QueueDeclare(queue: "accepted");
|
||||
channel.QueueBind(queue: "accepted",
|
||||
exchange: "report",
|
||||
routingKey: string.Empty);
|
||||
|
||||
Console.WriteLine(" [*] Waiting for messages.");
|
||||
|
||||
var consumer = new EventingBasicConsumer(channel);
|
||||
consumer.Received += async (model, ea) =>
|
||||
{
|
||||
byte[] body = ea.Body.ToArray();
|
||||
var message = Encoding.UTF8.GetString(body);
|
||||
|
||||
string outputText = $"Заявление принято к обработке {message}";
|
||||
Console.WriteLine($" [x] Done. {outputText}");
|
||||
channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
|
||||
};
|
||||
channel.BasicConsume(queue: "accepted",
|
||||
autoAck: false,
|
||||
consumer: consumer);
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
```
|
||||
|
||||
3. Consumer 3:
|
||||
```
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
using RabbitMQ.Client.Events;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
Random rand = new Random();
|
||||
string queueName = $"denied{rand.Next()}";
|
||||
|
||||
channel.QueueDeclare(queue: queueName);
|
||||
channel.QueueBind(queue: queueName,
|
||||
exchange: "report",
|
||||
routingKey: string.Empty);
|
||||
|
||||
Console.WriteLine(" [*] Waiting for messages.");
|
||||
|
||||
var consumer = new EventingBasicConsumer(channel);
|
||||
consumer.Received += async (model, ea) =>
|
||||
{
|
||||
byte[] body = ea.Body.ToArray();
|
||||
var message = Encoding.UTF8.GetString(body);
|
||||
|
||||
int waitTime = rand.Next(20, 90);
|
||||
Thread.Sleep(waitTime * 100);
|
||||
|
||||
string outputText = $"Заявление обработано {message} за {waitTime} минут";
|
||||
Console.WriteLine($" [x] Done. {outputText}");
|
||||
channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
|
||||
};
|
||||
channel.BasicConsume(queue: queueName,
|
||||
autoAck: false,
|
||||
consumer: consumer);
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
```
|
||||
|
||||
## Результаты выполнения работы
|
||||
|
||||
Запуск каждой программы:
|
||||
|
||||
|
||||
|
||||
|
||||
Результаты обработки:
|
||||
|
||||
|
||||
|
||||
Вывод: Consumer_2 нагружает меньше памяти, чем Consumer_1 и принимает сообщения гораздо быстрее, тем самым не позволяя очереди накапливать огромное количество сообщений
|
||||
92
tasks/mikhailov-ys/lab_4/lab_4.sln
Normal file
92
tasks/mikhailov-ys/lab_4/lab_4.sln
Normal file
@@ -0,0 +1,92 @@
|
||||
|
||||
Microsoft Visual Studio Solution File, Format Version 12.00
|
||||
# Visual Studio Version 17
|
||||
VisualStudioVersion = 17.5.002.0
|
||||
MinimumVisualStudioVersion = 10.0.40219.1
|
||||
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Main", "Main", "{964E2358-8624-4435-A0C6-5B4E3C44DB7A}"
|
||||
EndProject
|
||||
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Consumer1", "Main\Consumer1\Consumer1.csproj", "{62525D49-B416-41D2-92DC-3025ABD8FED2}"
|
||||
EndProject
|
||||
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Consumer2", "Main\Consumer2\Consumer2.csproj", "{71B9FCAD-EDBC-42C7-951E-2CEACB18B0AD}"
|
||||
EndProject
|
||||
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Publisher", "Main\Publisher\Publisher.csproj", "{DAE03D67-36C7-424E-87F3-3D900293BA39}"
|
||||
EndProject
|
||||
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "tut1", "tut1", "{E28D0800-55F2-44CC-AF62-9524F6E70A1B}"
|
||||
EndProject
|
||||
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Receive", "tut1\Receive\Receive.csproj", "{A8885758-2115-43E0-8672-5B0E2B33FB57}"
|
||||
EndProject
|
||||
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Send", "tut1\Send\Send.csproj", "{D2ABDEBD-9E8D-4F38-A5BF-7F469EDB9B8C}"
|
||||
EndProject
|
||||
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "tut2", "tut2", "{0E1855BF-5771-45F9-BB46-5D075DE99313}"
|
||||
EndProject
|
||||
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "NewTask", "tut2\NewTask\NewTask.csproj", "{F06A67F1-1606-4D01-84C6-10CE4F4A5273}"
|
||||
EndProject
|
||||
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Worker", "tut2\Worker\Worker.csproj", "{22F91487-772C-4DA4-9BAC-D6BB44B10D6C}"
|
||||
EndProject
|
||||
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "tut3", "tut3", "{D12C599A-23A2-4139-96A3-8188BC6135E2}"
|
||||
EndProject
|
||||
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "EmitLogs", "tut3\EmitLogs\EmitLogs.csproj", "{61B1A285-7B3C-4B60-8001-0757E6A88EA9}"
|
||||
EndProject
|
||||
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ReceiveLogs", "tut3\ReceiveLogs\ReceiveLogs.csproj", "{63AE28E6-F4E0-40E1-AAAC-F1C11111CFE8}"
|
||||
EndProject
|
||||
Global
|
||||
GlobalSection(SolutionConfigurationPlatforms) = preSolution
|
||||
Debug|Any CPU = Debug|Any CPU
|
||||
Release|Any CPU = Release|Any CPU
|
||||
EndGlobalSection
|
||||
GlobalSection(ProjectConfigurationPlatforms) = postSolution
|
||||
{62525D49-B416-41D2-92DC-3025ABD8FED2}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{62525D49-B416-41D2-92DC-3025ABD8FED2}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{62525D49-B416-41D2-92DC-3025ABD8FED2}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{62525D49-B416-41D2-92DC-3025ABD8FED2}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
{71B9FCAD-EDBC-42C7-951E-2CEACB18B0AD}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{71B9FCAD-EDBC-42C7-951E-2CEACB18B0AD}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{71B9FCAD-EDBC-42C7-951E-2CEACB18B0AD}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{71B9FCAD-EDBC-42C7-951E-2CEACB18B0AD}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
{DAE03D67-36C7-424E-87F3-3D900293BA39}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{DAE03D67-36C7-424E-87F3-3D900293BA39}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{DAE03D67-36C7-424E-87F3-3D900293BA39}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{DAE03D67-36C7-424E-87F3-3D900293BA39}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
{A8885758-2115-43E0-8672-5B0E2B33FB57}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{A8885758-2115-43E0-8672-5B0E2B33FB57}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{A8885758-2115-43E0-8672-5B0E2B33FB57}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{A8885758-2115-43E0-8672-5B0E2B33FB57}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
{D2ABDEBD-9E8D-4F38-A5BF-7F469EDB9B8C}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{D2ABDEBD-9E8D-4F38-A5BF-7F469EDB9B8C}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{D2ABDEBD-9E8D-4F38-A5BF-7F469EDB9B8C}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{D2ABDEBD-9E8D-4F38-A5BF-7F469EDB9B8C}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
{F06A67F1-1606-4D01-84C6-10CE4F4A5273}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{F06A67F1-1606-4D01-84C6-10CE4F4A5273}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{F06A67F1-1606-4D01-84C6-10CE4F4A5273}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{F06A67F1-1606-4D01-84C6-10CE4F4A5273}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
{22F91487-772C-4DA4-9BAC-D6BB44B10D6C}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{22F91487-772C-4DA4-9BAC-D6BB44B10D6C}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{22F91487-772C-4DA4-9BAC-D6BB44B10D6C}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{22F91487-772C-4DA4-9BAC-D6BB44B10D6C}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
{61B1A285-7B3C-4B60-8001-0757E6A88EA9}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{61B1A285-7B3C-4B60-8001-0757E6A88EA9}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{61B1A285-7B3C-4B60-8001-0757E6A88EA9}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{61B1A285-7B3C-4B60-8001-0757E6A88EA9}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
{63AE28E6-F4E0-40E1-AAAC-F1C11111CFE8}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{63AE28E6-F4E0-40E1-AAAC-F1C11111CFE8}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{63AE28E6-F4E0-40E1-AAAC-F1C11111CFE8}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{63AE28E6-F4E0-40E1-AAAC-F1C11111CFE8}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
EndGlobalSection
|
||||
GlobalSection(SolutionProperties) = preSolution
|
||||
HideSolutionNode = FALSE
|
||||
EndGlobalSection
|
||||
GlobalSection(NestedProjects) = preSolution
|
||||
{62525D49-B416-41D2-92DC-3025ABD8FED2} = {964E2358-8624-4435-A0C6-5B4E3C44DB7A}
|
||||
{71B9FCAD-EDBC-42C7-951E-2CEACB18B0AD} = {964E2358-8624-4435-A0C6-5B4E3C44DB7A}
|
||||
{DAE03D67-36C7-424E-87F3-3D900293BA39} = {964E2358-8624-4435-A0C6-5B4E3C44DB7A}
|
||||
{A8885758-2115-43E0-8672-5B0E2B33FB57} = {E28D0800-55F2-44CC-AF62-9524F6E70A1B}
|
||||
{D2ABDEBD-9E8D-4F38-A5BF-7F469EDB9B8C} = {E28D0800-55F2-44CC-AF62-9524F6E70A1B}
|
||||
{F06A67F1-1606-4D01-84C6-10CE4F4A5273} = {0E1855BF-5771-45F9-BB46-5D075DE99313}
|
||||
{22F91487-772C-4DA4-9BAC-D6BB44B10D6C} = {0E1855BF-5771-45F9-BB46-5D075DE99313}
|
||||
{61B1A285-7B3C-4B60-8001-0757E6A88EA9} = {D12C599A-23A2-4139-96A3-8188BC6135E2}
|
||||
{63AE28E6-F4E0-40E1-AAAC-F1C11111CFE8} = {D12C599A-23A2-4139-96A3-8188BC6135E2}
|
||||
EndGlobalSection
|
||||
GlobalSection(ExtensibilityGlobals) = postSolution
|
||||
SolutionGuid = {A916E577-C16A-4BBF-A3BE-9491C0F5B147}
|
||||
EndGlobalSection
|
||||
EndGlobal
|
||||
BIN
tasks/mikhailov-ys/lab_4/pic/1.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/1.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 17 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/10.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/10.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 71 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/11.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/11.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 56 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/12.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/12.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 63 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/13.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/13.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 37 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/14.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/14.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 61 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/15.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/15.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 77 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/2.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/2.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 16 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/3.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/3.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 78 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/4.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/4.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 24 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/5.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/5.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 21 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/6.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/6.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 40 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/7.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/7.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 82 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/8.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/8.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 6.2 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/9.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/9.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 7.7 KiB |
29
tasks/mikhailov-ys/lab_4/tut1/Receive/Receive.cs
Normal file
29
tasks/mikhailov-ys/lab_4/tut1/Receive/Receive.cs
Normal file
@@ -0,0 +1,29 @@
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
using RabbitMQ.Client.Events;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
channel.QueueDeclare(queue: "hello",
|
||||
durable: false,
|
||||
exclusive: false,
|
||||
autoDelete: false,
|
||||
arguments: null);
|
||||
|
||||
Console.WriteLine(" [*] Waiting for messages.");
|
||||
|
||||
var consumer = new EventingBasicConsumer(channel);
|
||||
consumer.Received += (model, ea) =>
|
||||
{
|
||||
var body = ea.Body.ToArray();
|
||||
var message = Encoding.UTF8.GetString(body);
|
||||
Console.WriteLine($" [x] Received {message}");
|
||||
};
|
||||
channel.BasicConsume(queue: "hello",
|
||||
autoAck: true,
|
||||
consumer: consumer);
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
@@ -8,7 +8,7 @@
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="BenchmarkDotNet" Version="0.13.11" />
|
||||
<PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
24
tasks/mikhailov-ys/lab_4/tut1/Send/Send.cs
Normal file
24
tasks/mikhailov-ys/lab_4/tut1/Send/Send.cs
Normal file
@@ -0,0 +1,24 @@
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
channel.QueueDeclare(queue: "hello",
|
||||
durable: false,
|
||||
exclusive: false,
|
||||
autoDelete: false,
|
||||
arguments: null);
|
||||
|
||||
const string message = "Hello World!";
|
||||
var body = Encoding.UTF8.GetBytes(message);
|
||||
|
||||
channel.BasicPublish(exchange: string.Empty,
|
||||
routingKey: "hello",
|
||||
basicProperties: null,
|
||||
body: body);
|
||||
Console.WriteLine($" [x] Sent {message}");
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
14
tasks/mikhailov-ys/lab_4/tut1/Send/Send.csproj
Normal file
14
tasks/mikhailov-ys/lab_4/tut1/Send/Send.csproj
Normal file
@@ -0,0 +1,14 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<OutputType>Exe</OutputType>
|
||||
<TargetFramework>net6.0</TargetFramework>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<Nullable>enable</Nullable>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
32
tasks/mikhailov-ys/lab_4/tut2/Task/Task.cs
Normal file
32
tasks/mikhailov-ys/lab_4/tut2/Task/Task.cs
Normal file
@@ -0,0 +1,32 @@
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
channel.QueueDeclare(queue: "task_queue",
|
||||
durable: true,
|
||||
exclusive: false,
|
||||
autoDelete: false,
|
||||
arguments: null);
|
||||
|
||||
var message = GetMessage(args);
|
||||
var body = Encoding.UTF8.GetBytes(message);
|
||||
|
||||
var properties = channel.CreateBasicProperties();
|
||||
properties.Persistent = true;
|
||||
|
||||
channel.BasicPublish(exchange: string.Empty,
|
||||
routingKey: "task_queue",
|
||||
basicProperties: properties,
|
||||
body: body);
|
||||
Console.WriteLine($" [x] Sent {message}");
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
|
||||
static string GetMessage(string[] args)
|
||||
{
|
||||
return ((args.Length > 0) ? string.Join(" ", args) : "Урок 2");
|
||||
}
|
||||
14
tasks/mikhailov-ys/lab_4/tut2/Task/Task.csproj
Normal file
14
tasks/mikhailov-ys/lab_4/tut2/Task/Task.csproj
Normal file
@@ -0,0 +1,14 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<OutputType>Exe</OutputType>
|
||||
<TargetFramework>net6.0</TargetFramework>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<Nullable>enable</Nullable>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
38
tasks/mikhailov-ys/lab_4/tut2/Worker/Worker.cs
Normal file
38
tasks/mikhailov-ys/lab_4/tut2/Worker/Worker.cs
Normal file
@@ -0,0 +1,38 @@
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
using RabbitMQ.Client.Events;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
channel.QueueDeclare(queue: "task_queue",
|
||||
durable: true,
|
||||
exclusive: false,
|
||||
autoDelete: false,
|
||||
arguments: null);
|
||||
|
||||
channel.BasicQos(prefetchSize: 0, prefetchCount: 1, global: false);
|
||||
|
||||
Console.WriteLine(" [*] Waiting for messages.");
|
||||
|
||||
var consumer = new EventingBasicConsumer(channel);
|
||||
consumer.Received += (model, ea) =>
|
||||
{
|
||||
byte[] body = ea.Body.ToArray();
|
||||
var message = Encoding.UTF8.GetString(body);
|
||||
Console.WriteLine($" [x] Received {message}");
|
||||
|
||||
int dots = message.Split('.').Length - 1;
|
||||
Thread.Sleep(dots * 1000);
|
||||
|
||||
Console.WriteLine(" [x] Done");
|
||||
|
||||
channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
|
||||
};
|
||||
channel.BasicConsume(queue: "task_queue",
|
||||
autoAck: false,
|
||||
consumer: consumer);
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
14
tasks/mikhailov-ys/lab_4/tut2/Worker/Worker.csproj
Normal file
14
tasks/mikhailov-ys/lab_4/tut2/Worker/Worker.csproj
Normal file
@@ -0,0 +1,14 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<OutputType>Exe</OutputType>
|
||||
<TargetFramework>net6.0</TargetFramework>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<Nullable>enable</Nullable>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
24
tasks/mikhailov-ys/lab_4/tut3/EmitLogs/EmitLogs.cs
Normal file
24
tasks/mikhailov-ys/lab_4/tut3/EmitLogs/EmitLogs.cs
Normal file
@@ -0,0 +1,24 @@
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
channel.ExchangeDeclare(exchange: "logs", type: ExchangeType.Fanout);
|
||||
|
||||
var message = GetMessage(args);
|
||||
var body = Encoding.UTF8.GetBytes(message);
|
||||
channel.BasicPublish(exchange: "logs",
|
||||
routingKey: string.Empty,
|
||||
basicProperties: null,
|
||||
body: body);
|
||||
Console.WriteLine($" [x] Sent {message}");
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
|
||||
static string GetMessage(string[] args)
|
||||
{
|
||||
return ((args.Length > 0) ? string.Join(" ", args) : "info: третий туториал");
|
||||
}
|
||||
14
tasks/mikhailov-ys/lab_4/tut3/EmitLogs/EmitLogs.csproj
Normal file
14
tasks/mikhailov-ys/lab_4/tut3/EmitLogs/EmitLogs.csproj
Normal file
@@ -0,0 +1,14 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<TargetFramework>net6.0</TargetFramework>
|
||||
<OutputType>Exe</OutputType>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<Nullable>enable</Nullable>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="RabbitMQ.Client" Version="6.4.0" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
31
tasks/mikhailov-ys/lab_4/tut3/ReceiveLogs/ReceiveLogs.cs
Normal file
31
tasks/mikhailov-ys/lab_4/tut3/ReceiveLogs/ReceiveLogs.cs
Normal file
@@ -0,0 +1,31 @@
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
using RabbitMQ.Client.Events;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
channel.ExchangeDeclare(exchange: "logs", type: ExchangeType.Fanout);
|
||||
|
||||
// declare a server-named queue
|
||||
var queueName = channel.QueueDeclare().QueueName;
|
||||
channel.QueueBind(queue: queueName,
|
||||
exchange: "logs",
|
||||
routingKey: string.Empty);
|
||||
|
||||
Console.WriteLine(" [*] Waiting for logs.");
|
||||
|
||||
var consumer = new EventingBasicConsumer(channel);
|
||||
consumer.Received += (model, ea) =>
|
||||
{
|
||||
byte[] body = ea.Body.ToArray();
|
||||
var message = Encoding.UTF8.GetString(body);
|
||||
Console.WriteLine($" [x] {message}");
|
||||
};
|
||||
channel.BasicConsume(queue: queueName,
|
||||
autoAck: true,
|
||||
consumer: consumer);
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
14
tasks/mikhailov-ys/lab_4/tut3/ReceiveLogs/ReceiveLogs.csproj
Normal file
14
tasks/mikhailov-ys/lab_4/tut3/ReceiveLogs/ReceiveLogs.csproj
Normal file
@@ -0,0 +1,14 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<TargetFramework>net6.0</TargetFramework>
|
||||
<OutputType>Exe</OutputType>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<Nullable>enable</Nullable>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="RabbitMQ.Client" Version="6.4.0" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
@@ -1,173 +0,0 @@
|
||||
using System;
|
||||
using System.Diagnostics;
|
||||
using System.Threading.Tasks;
|
||||
using BenchmarkDotNet.Attributes;
|
||||
using BenchmarkDotNet.Running;
|
||||
|
||||
public class MatrixMultiplication
|
||||
{
|
||||
public static int[][] MultiplySequential(int[][] matrixA, int[][] matrixB)
|
||||
{
|
||||
int rowsA = matrixA.Length;
|
||||
int colsA = matrixA[0].Length;
|
||||
int colsB = matrixB[0].Length;
|
||||
|
||||
int[][] result = new int[rowsA][];
|
||||
|
||||
for (int i = 0; i < rowsA; i++)
|
||||
{
|
||||
result[i] = new int[colsB];
|
||||
|
||||
for (int j = 0; j < colsB; j++)
|
||||
{
|
||||
for (int k = 0; k < colsA; k++)
|
||||
{
|
||||
result[i][j] += matrixA[i][k] * matrixB[k][j];
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
public static int[][] MultiplyParallel(int[][] matrixA, int[][] matrixB, int numThreads)
|
||||
{
|
||||
int rowsA = matrixA.Length;
|
||||
int colsA = matrixA[0].Length;
|
||||
int colsB = matrixB[0].Length;
|
||||
|
||||
int[][] result = new int[rowsA][];
|
||||
|
||||
Parallel.For(0, rowsA, new ParallelOptions { MaxDegreeOfParallelism = numThreads }, i =>
|
||||
{
|
||||
result[i] = new int[colsB];
|
||||
|
||||
for (int j = 0; j < colsB; j++)
|
||||
{
|
||||
for (int k = 0; k < colsA; k++)
|
||||
{
|
||||
result[i][j] += matrixA[i][k] * matrixB[k][j];
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
[Benchmark]
|
||||
public void MultiplySequential_100x100()
|
||||
{
|
||||
int[][] matrixA = GenerateRandomMatrix(100, 100);
|
||||
int[][] matrixB = GenerateRandomMatrix(100, 100);
|
||||
MultiplySequential(matrixA, matrixB);
|
||||
}
|
||||
|
||||
[Benchmark]
|
||||
public void MultiplyParallel_100x100_4TH()
|
||||
{
|
||||
int[][] matrixA = GenerateRandomMatrix(100, 100);
|
||||
int[][] matrixB = GenerateRandomMatrix(100, 100);
|
||||
MultiplyParallel(matrixA, matrixB, 4);
|
||||
}
|
||||
[Benchmark]
|
||||
public void MultiplyParallel_100x100_8TH()
|
||||
{
|
||||
int[][] matrixA = GenerateRandomMatrix(100, 100);
|
||||
int[][] matrixB = GenerateRandomMatrix(100, 100);
|
||||
MultiplyParallel(matrixA, matrixB, 8);
|
||||
|
||||
}
|
||||
[Benchmark]
|
||||
public void MultiplyParallel_100x100_16TH()
|
||||
{
|
||||
int[][] matrixA = GenerateRandomMatrix(100, 100);
|
||||
int[][] matrixB = GenerateRandomMatrix(100, 100);
|
||||
MultiplyParallel(matrixA, matrixB, 16);
|
||||
|
||||
}
|
||||
|
||||
[Benchmark]
|
||||
public void MultiplySequential_300x300()
|
||||
{
|
||||
int[][] matrixA = GenerateRandomMatrix(300, 300);
|
||||
int[][] matrixB = GenerateRandomMatrix(300, 300);
|
||||
MultiplySequential(matrixA, matrixB);
|
||||
}
|
||||
|
||||
[Benchmark]
|
||||
public void MultiplyParallel_300x300_4TH()
|
||||
{
|
||||
int[][] matrixA = GenerateRandomMatrix(300, 300);
|
||||
int[][] matrixB = GenerateRandomMatrix(300, 300);
|
||||
MultiplyParallel(matrixA, matrixB, 4);
|
||||
}
|
||||
[Benchmark]
|
||||
public void MultiplyParallel_300x300_8TH()
|
||||
{
|
||||
int[][] matrixA = GenerateRandomMatrix(300, 300);
|
||||
int[][] matrixB = GenerateRandomMatrix(300, 300);
|
||||
MultiplyParallel(matrixA, matrixB, 8);
|
||||
}
|
||||
[Benchmark]
|
||||
public void MultiplyParallel_300x300_16TH()
|
||||
{
|
||||
int[][] matrixA = GenerateRandomMatrix(300, 300);
|
||||
int[][] matrixB = GenerateRandomMatrix(300, 300);
|
||||
MultiplyParallel(matrixA, matrixB, 16);
|
||||
}
|
||||
[Benchmark]
|
||||
public void MultiplySequential_500x500()
|
||||
{
|
||||
int[][] matrixA = GenerateRandomMatrix(500, 500);
|
||||
int[][] matrixB = GenerateRandomMatrix(500, 500);
|
||||
MultiplySequential(matrixA, matrixB);
|
||||
}
|
||||
|
||||
[Benchmark]
|
||||
public void MultiplyParallel_500x500_4TH()
|
||||
{
|
||||
int[][] matrixA = GenerateRandomMatrix(500, 500);
|
||||
int[][] matrixB = GenerateRandomMatrix(500, 500);
|
||||
MultiplyParallel(matrixA, matrixB, 4);
|
||||
}
|
||||
[Benchmark]
|
||||
public void MultiplyParallel_500x500_8TH()
|
||||
{
|
||||
int[][] matrixA = GenerateRandomMatrix(500, 500);
|
||||
int[][] matrixB = GenerateRandomMatrix(500, 500);
|
||||
MultiplyParallel(matrixA, matrixB, 8);
|
||||
}
|
||||
[Benchmark]
|
||||
public void MultiplyParallel_500x500_16TH()
|
||||
{
|
||||
int[][] matrixA = GenerateRandomMatrix(500, 500);
|
||||
int[][] matrixB = GenerateRandomMatrix(500, 500);
|
||||
MultiplyParallel(matrixA, matrixB, 16);
|
||||
}
|
||||
private static int[][] GenerateRandomMatrix(int rows, int cols)
|
||||
{
|
||||
int[][] matrix = new int[rows][];
|
||||
|
||||
Random rand = new Random();
|
||||
|
||||
for (int i = 0; i < rows; i++)
|
||||
{
|
||||
matrix[i] = new int[cols];
|
||||
for (int j = 0; j < cols; j++)
|
||||
{
|
||||
matrix[i][j] = rand.Next(1, 10);
|
||||
}
|
||||
}
|
||||
|
||||
return matrix;
|
||||
}
|
||||
}
|
||||
|
||||
class Program
|
||||
{
|
||||
static void Main(string[] args)
|
||||
{
|
||||
var summary = BenchmarkRunner.Run<MatrixMultiplication>();
|
||||
Console.ReadLine();
|
||||
}
|
||||
}
|
||||
@@ -1,66 +0,0 @@
|
||||
# Отчёт по лабораторной работе №5
|
||||
|
||||
Выполнил: студент гр. ИСЭбд-41 Михайлов Ю.С.
|
||||
|
||||
## Запуск приложения
|
||||
|
||||
Было выбрано консольное приложение, язык программирования - C#.
|
||||
|
||||
Перемножение матриц обычным алгоритмом:
|
||||
```
|
||||
public static int[][] MultiplySequential(int[][] matrixA, int[][] matrixB)
|
||||
{
|
||||
int rowsA = matrixA.Length;
|
||||
int colsA = matrixA[0].Length;
|
||||
int colsB = matrixB[0].Length;
|
||||
|
||||
int[][] result = new int[rowsA][];
|
||||
|
||||
for (int i = 0; i < rowsA; i++)
|
||||
{
|
||||
result[i] = new int[colsB];
|
||||
|
||||
for (int j = 0; j < colsB; j++)
|
||||
{
|
||||
for (int k = 0; k < colsA; k++)
|
||||
{
|
||||
result[i][j] += matrixA[i][k] * matrixB[k][j];
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return result;
|
||||
}
|
||||
```
|
||||
|
||||
Перемножение матриц параллельным алгоритмом:
|
||||
```
|
||||
public static int[][] MultiplyParallel(int[][] matrixA, int[][] matrixB, int numThreads)
|
||||
{
|
||||
int rowsA = matrixA.Length;
|
||||
int colsA = matrixA[0].Length;
|
||||
int colsB = matrixB[0].Length;
|
||||
|
||||
int[][] result = new int[rowsA][];
|
||||
|
||||
Parallel.For(0, rowsA, new ParallelOptions { MaxDegreeOfParallelism = numThreads }, i =>
|
||||
{
|
||||
result[i] = new int[colsB];
|
||||
|
||||
for (int j = 0; j < colsB; j++)
|
||||
{
|
||||
for (int k = 0; k < colsA; k++)
|
||||
{
|
||||
result[i][j] += matrixA[i][k] * matrixB[k][j];
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
return result;
|
||||
}
|
||||
```
|
||||
|
||||
## Результаты
|
||||
|
||||
|
||||
Вывод: если в матрице не слишком много элементов, обычный алгоритм работает быстрее. Параллельный алгоритм следует использовать для обработки большого количества данных. В сравнении с однопоточным алгоритмом, работа параллельного в несколько раз быстрее.
|
||||
Binary file not shown.
|
Before Width: | Height: | Size: 34 KiB |
Reference in New Issue
Block a user