david/gpd-924-en
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add multithreading project

Browse Source
This commit is contained in:
david
2025-06-30 18:26:56 +02:00
parent a6dbfb224f
commit df5e59e4bf
9 changed files with 416 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Multithreading/.gitignore
+133
View File
@@ -0,0 +1,133 @@
## Ignore Visual Studio temporary files, build results, and
## files generated by popular Visual Studio add-ons.
# User-specific files
*.suo
*.user
*.sln.docstates
# Build results
[Dd]ebug/
[Rr]elease/
x64/
[Bb]in/
[Oo]bj/
# MSTest test Results
[Tt]est[Rr]esult*/
[Bb]uild[Ll]og.*
*_i.c
*_p.c
*_i.h
*.ilk
*.meta
*.obj
*.pch
*.pdb
*.pgc
*.pgd
*.rsp
*.sbr
*.tlb
*.tli
*.tlh
*.tmp
*.tmp_proj
*.log
*.vspscc
*.vssscc
.builds
*.pidb
*.log
*.svclog
*.scc
# Visual C++ cache files
ipch/
*.aps
*.ncb
*.opensdf
*.sdf
*.cachefile
# Visual Studio profiler
*.psess
*.vsp
*.vspx
# Guidance Automation Toolkit
*.gpState
# ReSharper is a .NET coding add-in
_ReSharper*/
*.[Rr]e[Ss]harper
*.DotSettings.user
# Click-Once directory
publish/
# Publish Web Output
*.Publish.xml
*.pubxml
*.azurePubxml
# NuGet Packages Directory
## TODO: If you have NuGet Package Restore enabled, uncomment the next line
packages/
## TODO: If the tool you use requires repositories.config, also uncomment the next line
!packages/repositories.config
# Windows Azure Build Output
csx/
*.build.csdef
# Windows Store app package directory
AppPackages/
# Others
sql/
*.Cache
ClientBin/
[Ss]tyle[Cc]op.*
![Ss]tyle[Cc]op.targets
~$*
*~
*.dbmdl
*.[Pp]ublish.xml
*.publishsettings
# RIA/Silverlight projects
Generated_Code/
# Backup & report files from converting an old project file to a newer
# Visual Studio version. Backup files are not needed, because we have git ;-)
_UpgradeReport_Files/
Backup*/
UpgradeLog*.XML
UpgradeLog*.htm
# SQL Server files
App_Data/*.mdf
App_Data/*.ldf
# =========================
# Windows detritus
# =========================
# Windows image file caches
Thumbs.db
ehthumbs.db
# Folder config file
Desktop.ini
# Recycle Bin used on file shares
$RECYCLE.BIN/
# Mac desktop service store files
.DS_Store
_NCrunch*
Multithreading/.idea/.idea.Multithreading/.idea/.gitignore
Generated
+8
View File
@@ -0,0 +1,8 @@
# Default ignored files
/shelf/
/workspace.xml
# Rider ignored files
/modules.xml
/projectSettingsUpdater.xml
/.idea.Multithreading.iml
/contentModel.xml
Multithreading/.idea/.idea.Multithreading/.idea/encodings.xml
Generated
+4
View File
@@ -0,0 +1,4 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="Encoding" addBOMForNewFiles="with BOM under Windows, with no BOM otherwise" />
</project>
Multithreading/.idea/.idea.Multithreading/.idea/indexLayout.xml
Generated
+8
View File
@@ -0,0 +1,8 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="UserContentModel">
<attachedFolders />
<explicitIncludes />
<explicitExcludes />
</component>
</project>
Multithreading/.idea/.idea.Multithreading/.idea/vcs.xml
Generated
+6
View File
@@ -0,0 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="VcsDirectoryMappings">
<mapping directory="$PROJECT_DIR$/.." vcs="Git" />
</component>
</project>
Multithreading/Multithreading.sln
+16
View File
@@ -0,0 +1,16 @@
Microsoft Visual Studio Solution File, Format Version 12.00
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Multithreading", "Multithreading\Multithreading.csproj", "{03A1EA82-F21F-45B0-A6D2-3275164FD3E9}"
EndProject
Global
GlobalSection(SolutionConfigurationPlatforms) = preSolution
Debug|Any CPU = Debug|Any CPU
Release|Any CPU = Release|Any CPU
EndGlobalSection
GlobalSection(ProjectConfigurationPlatforms) = postSolution
{03A1EA82-F21F-45B0-A6D2-3275164FD3E9}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{03A1EA82-F21F-45B0-A6D2-3275164FD3E9}.Debug|Any CPU.Build.0 = Debug|Any CPU
{03A1EA82-F21F-45B0-A6D2-3275164FD3E9}.Release|Any CPU.ActiveCfg = Release|Any CPU
{03A1EA82-F21F-45B0-A6D2-3275164FD3E9}.Release|Any CPU.Build.0 = Release|Any CPU
EndGlobalSection
EndGlobal
Multithreading/Multithreading/Multithreading.csproj
+10
View File
@@ -0,0 +1,10 @@
<Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup>
<OutputType>Exe</OutputType>
<TargetFramework>net8.0</TargetFramework>
<ImplicitUsings>disable</ImplicitUsings>
<Nullable>enable</Nullable>
</PropertyGroup>
</Project>
Multithreading/Multithreading/Tasks.cs
+127
View File
@@ -0,0 +1,127 @@
using System;
using System.Threading;
using System.Threading.Tasks;
namespace Multithreading
{
internal class Program
{
public static void Main(string[] args)
{
Console.WriteLine("Program started");
// Task task = new Task(() =>
// {
// for (int i = 0; i < 10; i++)
// {
// Console.WriteLine($"Task ({Thread.CurrentThread.ManagedThreadId}): {i}");
// Thread.Sleep(500);
// }
// });
// task.Start();
//
// Task task2 = Task.Run(() =>
// {
// for (int i = 0; i < 10; i++)
// {
// Console.WriteLine($"Task ({Thread.CurrentThread.ManagedThreadId}): {i}");
// Thread.Sleep(500);
// }
// });
//
// task.Wait();
// task2.Wait();
//
// Task task3 = new Task(() =>
// {
// for (int i = 0; i < 10; i++)
// {
// Console.WriteLine($"Task ({Thread.CurrentThread.ManagedThreadId}): {i}");
// Thread.Sleep(500);
// }
// });
// task3.RunSynchronously();
// CancellationTokenSource cts = new CancellationTokenSource();
// CancellationToken token = cts.Token;
//
// Task task4 = Task.Run(() =>
// {
// for (int i = 0; i < 10; i++)
// {
// Console.WriteLine($"Task ({Thread.CurrentThread.ManagedThreadId}): {i}");
// Thread.Sleep(500);
//
// // token.ThrowIfCancellationRequested();
// if (token.IsCancellationRequested)
// {
// // throw new TaskCanceledException();
// break;
// }
// }
// }, token);
//
// ConsoleKeyInfo keyInfo = Console.ReadKey();
// if (keyInfo.Key == ConsoleKey.A) cts.Cancel();
//
// try
// {
// task4.Wait(token);
// }
// catch (OperationCanceledException e)
// {
// Console.WriteLine(e);
// }
//
// cts.Dispose();
// CancellationTokenSource cts2 = new CancellationTokenSource();
Random random = new Random();
Task[] tasks = new Task[10];
for (int i = 0; i < tasks.Length; i++)
{
tasks[i] = Task.Run(() =>
{
Console.WriteLine($"Task ({Thread.CurrentThread.ManagedThreadId}) started");
for (int j = 0; j < 10; j++)
{
Console.WriteLine($"Task ({Thread.CurrentThread.ManagedThreadId}): {j}");
Thread.Sleep(random.Next(100, 1000));
if (random.NextSingle() > 0.9f)
{
Console.WriteLine($"Task ({Thread.CurrentThread.ManagedThreadId}) aborted");
// cts2.Cancel();
throw new OperationCanceledException();
}
}
Console.WriteLine($"Task ({Thread.CurrentThread.ManagedThreadId}) ended");
});
Console.WriteLine($"Task with id {tasks[i].Id} created");
Console.WriteLine($"Task ({tasks[i].Id}): {tasks[i].Status}");
}
try
{
Task.WaitAll(tasks);
// Task.WaitAny(tasks);
}
catch (OperationCanceledException)
{
Console.WriteLine("Operation was canceled");
}
catch (AggregateException)
{
Console.WriteLine("One or more tasks canceled");
}
for (int i = 0; i < tasks.Length; i++)
{
Console.WriteLine($"Task ({tasks[i].Id}): {tasks[i].Status}");
}
Console.WriteLine("Program ended");
}
}
}
Multithreading/Multithreading/Threads.cs
+104
View File
@@ -0,0 +1,104 @@
// using System;
// using System.Threading;
//
// namespace Multithreading
// {
// internal class Program
// {
// private static bool _shouldExit;
//
// public static void Main(string[] args)
// {
// Console.WriteLine("Program started");
//
// // Console.WriteLine($"{Thread.CurrentThread.Name}");
// // Console.WriteLine($"{Thread.CurrentThread.ManagedThreadId}");
// //
// // Console.WriteLine("Before Sleep");
// // Thread.Sleep(10000);
// // Console.WriteLine("After Sleep");
//
// // Console.ReadKey();
//
// // Thread thread = new Thread(() =>
// // {
// // for (int i = 0; i < 10; i++)
// // {
// // Console.WriteLine($"Thread ({Thread.CurrentThread.ManagedThreadId}): {i}");
// // Thread.Sleep(500);
// // }
// // });
// // thread.IsBackground = true;
// // thread.Start();
// //
// // Thread[] threads = new Thread[10];
// // for (int i = 0; i < threads.Length; i++)
// // {
// // threads[i] = new Thread(PrintAndSleep);
// // // threads[i].IsBackground = true;
// // threads[i].Start();
// // }
//
// // for (int i = 0; i < 10; i++)
// // {
// // Console.WriteLine($"Main: {i}");
// // Thread.Sleep(250);
// // }
// //
// // thread.Join();
// // Console.WriteLine($"Thread {thread.ManagedThreadId} is finished with {thread.ThreadState}");
// //
// // // thread.Start(); // CAUTION: you can not restart a thread
// //
// // for (int i = 0; i < threads.Length; i++)
// // {
// // threads[i].Join(5000);
// // Console.WriteLine($"Thread {threads[i].ManagedThreadId} is finished with {threads[i].ThreadState}");
// // // _shouldExit = true;
// // // Console.WriteLine($"Thread {threads[i].ManagedThreadId} is finished with {threads[i].ThreadState}");
// // // threads[i].Join(5000);
// // // Console.WriteLine($"Thread {threads[i].ManagedThreadId} is finished with {threads[i].ThreadState}");
// // }
// //
// // for (int i = 0; i < threads.Length; i++)
// // {
// // threads[i] = new Thread(PrintAndSleep);
// // threads[i].Start();
// // }
//
// Console.WriteLine("------------ THREADPOOL ------------");
//
// // ThreadPool.SetMaxThreads(1, 1);
//
// for (int i = 0; i < 10; i++)
// {
// ThreadPool.QueueUserWorkItem(_ => PrintAndSleep());
// }
//
// Thread.Sleep(5000);
//
// for (int i = 0; i < 10; i++)
// {
// ThreadPool.QueueUserWorkItem(_ => PrintAndSleep());
// }
//
// Thread.Sleep(5000);
//
// Console.WriteLine("Program ended");
// }
//
// private static void PrintAndSleep()
// {
// Console.WriteLine($"Thread ({Thread.CurrentThread.ManagedThreadId}) started");
// for (int i = 0; i < 5; i++)
// {
// if (_shouldExit) return;
//
// Console.WriteLine($"Thread ({Thread.CurrentThread.ManagedThreadId}): {i}");
// Thread.Sleep(500);
// }
// Console.WriteLine($"Thread ({Thread.CurrentThread.ManagedThreadId}) ended");
// }
// }
// }
//