Осторожно, ниже костыль и использование Task не по назначению:
class MyObject { }
class MyClass
{
public MyObject myobject;
public Task<MyObject> TaskMyObject;
public MyClass()
{
TaskMyObject = new Task<MyObject>(GetMyObject);
}
public MyObject GetMyObject() => myobject;
public void parentResume() => TaskMyObject.Start(); //тут косяк
public void parentResumeNew() //тут косяк
{
try
{
TaskMyObject.Start();
}
catch(Exception ex) { ExceptionToLog(ex); }
}
}
void SendToController(MyClass _MyClass) //выполняется в отдельном потоке
{
//Do something
_MyClass.myobject = //set something
_MyClass.parentResume();
}
public (bool, MyObject) Execute()
{
MyClass _MyClass = new MyClass();
SendToController(_MyClass); //код метода SendToController выполняется в отдельном потоке
bool time_success = _MyClass.TaskMyObject.Wait(delay);
return (time_success, _MyClass.myobject);
}
Суть кода:
- Принять Execute()
- Отослать в контроллер (который крутит отдельный поток) задачу MyClass через SendToController
- Запустить Wait для ожидания завершения операции
- Контроллер выполняет задачу из MyClass, записывает в него ответ MyObject
- Контроллер возобновляет работу метода Execute вызовом parentResume()
- TaskMyObject.Wait() ждёт либо возобновления через parentResume(), либо таймаута
- Execute() возвращает ответ - был ли превышен delay и ответ MyObject
Писал этот код давно (больше 2х лет назад), раньше он работал как часы, на потоках с бесконечным таймаутом, мьютексах - получалось не так эффективно, поэтому использовал Task. Т.е. Task используется исключительно как пауза с автовозобновлением.
Вчера произошёл вылет с ошибкой System.InvalidOperationException: Start may not be called on a task that was already started.
в parentResume() => TaskMyObject.Start();
До этого всё работало без малейших заиканий.
После чего я добавил метод parentResumeNew()
и использовал его вместо parentResume()
и теперь Start may not be called on a task that was already started.
я вижу в логе довольно часто. Но, несмотря на это, ответ MyObject я получаю корректно.
В связи с чем у меня возникает вопрос: не запускает ли Task.Wait() задачу (есть ли внутри Task.Start()
), и если да - то как сделать ожидание ответа (обработок в SendToController) или таймаута через Task без возобновления работы Execute раньше времени?
Или проблема вообще в другом месте?
Start()
просто запускает код делегата. Повторный вызовStart()
раньше ничего не делал, а теперь бросает исключение. Но я так и не понял, что это за зверь и какую задачу он решает. В любом случае оно "работало" не так как вам казалось.Wait()
ничего никогда не запускал и не запускает. Он просто вешает текущий поток.Wait() ничего никогда не запускал
- это отлично, значит у меня где-то повторный вызов resume.API1(thread1) -> Execute(thread1) -> SendToController(thread2) -> API2(thread2) -> parentResume(thread3) -> Execute(thread1) -> API1(thread1)
Просто на момент создания франкенштейна через мьютексы ничего не получалось, а созданный вручную поток оставался висеть в случае ошибки на участке SendToController(DoSomething), чем вызывал утечку памяти. Бесконечный цикл с ручным токеном жрал кучу ресурсов, только с Task всё ок