Передача параметра в Task.Factory.StartNew

Question

Учитывая следующий код:

string injectedString = "Read string out of HttpContext"; 
Task.Factory.StartNew(() => 
{ 
    MyClass myClass = new MyClass(); 
    myClass.Method(injectedString); 
} 

Это лучший способ передать строку в Task/Thread?

Мои проблемы с этим методом:

• ли сборщик мусора знать, когда строка стала из контекста и правильно очистить его?
• Есть ли лучший способ встраивания зависимостей в задачу, нарушающую связь с объектом в основном потоке?

Это в веб-сервисе Asp.Net, если это имеет значение и является потоком огня и забытого типа, я не жду никакого ответа.

Моя строка на самом деле происходит, чтобы считывать из HttpContext, что одна из причин, почему я впрыскиванием таким образом (Thread не имеет доступа к призывающих потоков HtppContext)

Answer 1

Ваш лямбда будет выведен в класс, сгенерированный компилятором. Переменная injectedString станет полем этого класса.

Таким образом, это будет сбор мусора, когда сгенерированный класс выходит за рамки (который находится в основном в самом конце вашей лямбда), и GC решает выполнить сбор.

В ответ на ваш комментарий:

Там нет дублирования. Компилятор превращает это:

string injectedString = "Read string out of HttpContext"; 
Task.Factory.StartNew(() => 
{ 
    MyClass myClass = new MyClass(); 
    myClass.Method(injectedString); 
} 

В это:

CompilerGeneratedClass c1 = new CompilerGeneratedClass(); 
c1.injectedString = "Read string out of HttpContext"; 
// call delegate here. 

Помните также: Строки интернированы в CLR. Даже если код был дублирован, строковые литералы будут интернированы в пуле. У вас, по существу, будет только родной WORD размерный дубликат, который указывает на строку (только строковые литералы ..)

Answer 2

Вы, вероятно, следует использовать Task.Factory.StartNew(Action<object> action, object state) перегрузка, чтобы передать состояние в вашу новую задачу.

Task.Factory.StartNew((object myState) => { 
    var i = (int)myState; 

    //Do calculations... 
    var x = i + 10; 
}, 10); 

Answer 3

Если вы обеспокоены injectedString может быть «сборки мусора» перед myClass.Method(injectedString); работает?

Ответа на этот вопрос не было. Вам не нужно об этом беспокоиться, потому что injectedString больше не является локальной переменной, когда она закрыта в lambda. Он станет полем нового класса, сгенерированного компилятором.

Если вас беспокоит, сборщик мусора соберет его в нужное время? Ответа на этот вопрос yes Это будет делать, если экземпляр этого класса выходит из области видимости и не ссылается на него в управляемом коде. Это произойдет, конечно, после того, как Taskзакроется и выходит из сферы действия.

Answer 4

class Program 
    { 
     static readonly ConcurrentQueue<int> mockItems = new ConcurrentQueue<int>(Enumerable.Range(0, 100)); 
     static CancellationToken token; 
     static CancellationTokenSource tokenSource; 
     static void Main(string[] args) 
     { 
      tokenSource = new CancellationTokenSource(); 
      token = tokenSource.Token; 

      for (int i = 0; i < 5; i++) 
      { 
       Task.Factory.StartNew(delegate { StartProcess(); }, tokenSource.Token, TaskCreationOptions.LongRunning); 
      } 
      Console.Read(); 
      tokenSource.Cancel(); 

     } 
     private static void StartProcess() 
     { 
      while (true) 
      { 
       if (token.IsCancellationRequested) 
        break; 

       int result; 
       mockItems.TryDequeue(out result); 

       Console.WriteLine(result); 
       Thread.Sleep(1000); 
      } 

     } 
    }