Добавила решение 3 домашней работы by Nigma-Ks · Pull Request #3 · Nigma-Ks/Homework_III_term

Nigma-Ks · 2024-03-27T12:06:16Z

No description provided.

yurii-litvinov

Полностью повторяет решение https://github.com/AnNyiiik/HWThirdTerm/pull/3/files#diff-4bad84ce6514350bfacc97c66857ef336944fc356d7a01ebc4f3edb3b6478150. Все списанные домашние работы надо будет полностью с нуля переделать и показывать вживую, умея отвечать на вопросы по решению и вносить правки.

yurii-litvinov

Вот тут Вы пока довольно далеки от правильного решения, хотя определёно движетесь в верном направлении :) Постарайтесь аккуратно самостоятельно разобраться — если получится, любое многопоточное программирование Вам легко дастся.

yurii-litvinov · 2024-04-07T10:10:48Z

Homework3.Tests/MyTreadPoolTests.cs

+    readonly int amountOfThreads = 5;
+    MyThreadPool threadPool;


Надо модификаторы видимости

Не поправлено

yurii-litvinov · 2024-04-07T10:11:17Z

Homework3.Tests/MyTreadPoolTests.cs

@@ -0,0 +1,95 @@
+


Тут наверняка будут актуальны многие из замечаний по стайлгайду из задачи про Lazy, их тут тоже надо поправить. Не буду их повторять.

yurii-litvinov · 2024-04-07T10:14:43Z

Homework3.Tests/MyTreadPoolTests.cs

+        var myTask = threadPool.Submit(() =>
+        {
+            throw new InvalidOperationException();
+            return 4; //without this string test doesn't work


Тут, скорее всего, проблема с тем, что без return тип лямбды не вывести. Можно добавить явную аннотацию типа: https://learn.microsoft.com/en-us/dotnet/csharp/language-reference/operators/lambda-expressions#explicit-return-type

Homework3.Tests/MyTreadPoolTests.cs

+
+        Assert.That(values.Count, Is.EqualTo(amountOfThreads));
+    }
+}


Homework3/IMyTask.cs

@@ -0,0 +1,24 @@
+using static Homework3.MyThreadPool;
+
+public interface IMyTask<T>


yurii-litvinov · 2024-04-07T10:26:48Z

Homework3/MyThreadPool.cs

+        public bool IsCompleted()
+        {
+            return isResultReady;
+        }


Suggested change

public bool IsCompleted()

{

return isResultReady;

}

public bool IsCompleted()

=> isResultReady;

yurii-litvinov · 2024-04-07T10:27:23Z

Homework3/MyThreadPool.cs

+        {
+            if (!isResultReady)
+            {
+                myTaskThreadHandler.Reset();


Homework3/MyThreadPool.cs

+            }
+            if (Volatile.Read(ref exception) == null)
+            {
+                return result;


yurii-litvinov · 2024-04-07T10:30:04Z

Homework3/MyThreadPool.cs

+        public MyTask(MyThreadPool myThreadPool, Func<T> function)
+        {
+            this.myThreadPool = myThreadPool;
+            this.myThreadPool.taskQueque.Enqueue(new Action(() =>


Вообще, лучше, чтобы сам объект делал свою работу. Тут на самом деле тредпулу надо много всякой внутренней синхронизации проделать (у Вас пока потребность в этом не возникла, потому что пока что он делает совсем не то, что должен), и MyTask это очень тяжело будет сделать правильно.

yurii-litvinov · 2024-04-07T10:30:36Z

Homework3/MyThreadPool.cs

+        {
+            if (!myThreadPool.cancellationTokenSource.IsCancellationRequested)
+            {
+                var nextFunction = new Func<T2>(() => continueFunction(Result()));


Опять-таки, никто не обещал, что в этом месте Shutdown ещё не отработал

yurii-litvinov · 2024-04-17T12:38:39Z

Homework3.Tests/MyTreadPoolTests.cs

+            {
+                tasks[localI] = threadPool.Submit(() =>
+                {
+                    manualResetEvent.WaitOne();


Нам было бы интереснее попробовать Submit делать одновременно, а не задачи, уже поставленные на пул, одновременно стартовать

yurii-litvinov · 2024-04-17T12:39:41Z

Homework3.Tests/MyTreadPoolTests.cs

+        {
+            Assert.That(tasks[i].Result(), Is.EqualTo(4));
+        }
+    }


Много потоков, делающих Submit, проверяется, но единственный ли это источник потенциальных гонок в этой задаче?

yurii-litvinov · 2024-04-17T12:40:03Z

Homework3/IMyTask.cs

+    /// <typeparam name="T2"></typeparam>
+    /// <param name="continueFunction"></param>
+    /// <returns></returns>


Не поправлено

yurii-litvinov · 2024-04-17T12:40:46Z

Homework3/MyThreadPool.cs

+        {
+            thread.Start();
+        }
+


Перед } пустая строка не ставится

yurii-litvinov · 2024-04-17T12:41:25Z

Homework3/MyThreadPool.cs

+public class MyThreadPool
+{
+    private readonly int timeForEndingWork = 1000;
+    private readonly object cancellationTokenLockObject = new();


Странное название, будто этот объект имеет какое-то отношение к cancellationToken именно

yurii-litvinov · 2024-04-17T12:41:44Z

Homework3/MyThreadPool.cs

+
+

Suggested change

yurii-litvinov · 2024-04-17T12:41:52Z

Homework3/MyThreadPool.cs

+    {
+        taskQueue.Enqueue(action);
+        threadCanWorkHandler.Set();
+        return;


Suggested change

return;

yurii-litvinov · 2024-04-17T12:44:00Z

Homework3/MyThreadPool.cs

+            var isSuccessullyRemoved = taskQueue.TryDequeue(out Action? newAction);
+            if (isSuccessullyRemoved)
+            {
+                Interlocked.Add(ref amountOfWorkingThreads, 1);


Interlocked.Increment

yurii-litvinov · 2024-04-17T13:15:19Z

Homework3/MyThreadPool.cs

+                if (!myThreadPool.cancellationTokenSource.IsCancellationRequested)
+                {
+                    var nextFunction = new Func<TContinuationResult>(() => continueFunction(Result()));
+                    return new MyTask<TContinuationResult>(myThreadPool, nextFunction);


Это сразу ставит в пул задачу-continuation, хотя она не может стартовать, пока первая задача не закончится. Получается, что если мы, скажем, поставим в пул задачу на 2 часа, потом 100 continuation-ов к ней на 1 секунду, то один поток из пула будет делать первую задачу, остальные потоки стоять на 165 строчке и не мочь делать другие, готовые к исполнению, задачи. Тут надо хитрее — если задача готова, ставить на пул, иначе складывать во временную очередь, и по готовности добавлять на пул (но подумать, что будет, если пул остановлен).

yurii-litvinov · 2024-04-17T13:15:40Z

Homework3/MyThreadPool.cs

+                    return new MyTask<TContinuationResult>(myThreadPool, nextFunction);
+                }
+            }
+            throw new InvalidOperationException("Shutdown was requested, threadpool stoped calculating");


Suggested change

throw new InvalidOperationException("Shutdown was requested, threadpool stoped calculating");

throw new InvalidOperationException("Shutdown was requested, threadpool stopped calculating");

Nigma-Ks added 2 commits March 27, 2024 14:51

Добавлено решение 3 домашней работы

ba47c8f

Удалила лишний файл

a020537

yurii-litvinov suggested changes Apr 1, 2024

View reviewed changes

Все переделала

66cc5da

Nigma-Ks force-pushed the hw3 branch from 73f7093 to 66cc5da Compare April 2, 2024 23:02

auto -> manual

1a2d04d

yurii-litvinov suggested changes Apr 7, 2024

View reviewed changes

Nigma-Ks added 3 commits April 16, 2024 19:58

Поправила замечания

2e62337

volatile write

2788e4c

Исправила опечатку в комментарии

ed1d3b2

yurii-litvinov suggested changes Apr 17, 2024

View reviewed changes

		@@ -0,0 +1,24 @@
		using static Homework3.MyThreadPool;

		public interface IMyTask<T>

	throw new InvalidOperationException("Shutdown was requested, threadpool stoped calculating");
	throw new InvalidOperationException("Shutdown was requested, threadpool stopped calculating");

Conversation

Nigma-Ks commented Mar 27, 2024

Uh oh!

yurii-litvinov left a comment

Choose a reason for hiding this comment

Uh oh!

yurii-litvinov left a comment

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

This comment was marked as resolved.

Uh oh!

This comment was marked as resolved.

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

This comment was marked as resolved.

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

2 participants