Ивент с реакцией в другом потоке

public void Monitor()
{
  while(true)
  {
    if(A > 4)
    {
      DO()
    }
  }
}

public event EventHandler MyEvent;
public void Monitor()
{
  while(true)
  {
    if(A > 4)
    {
      MyEvent(this, null);
    }
  }
}

int count = 0; 
private Thread t = new Thread(() => 
{
   while(true)
   {
      OnMyEvent(); 
      count --; 
      if (count == 0)
         monitor.Wait();
   }
});
 
void WhereEventIsRising()
{
   if (blabla)
      count++;
   if (count > 0) // Если есть в очереди появились элементы
      monitor.Pulse();
   
}

f (count == 0)
         monitor.Wait();

while(true);

public void DO()
{
  int А =0;
  for(int i = 0;i<10;i++)
  {
   А++;
  // Здесь должен вызыватся ивент асинхронно, говоря от том, что А изменилось. Что должно быть здесь ?
  }
}

public void Monitor()
{
  // Ага! А изменилось...
  // Обработка и выход
}

        BlockingCollection<int> queue = new BlockingCollection<int>(new ConcurrentQueue<int>()); //очередь элементов на вызов события
 
        public void DO()
        {
            CancellationTokenSource s = new CancellationTokenSource();
            new Thread(Monitor).Start(s.Token);
            int A = 0;
            for (int i = 0; i < 10; i++)
            {
                A++;
                queue.Add(A); // Здесь должен вызыватся ивент асинхронно, говоря от том, что А изменилось. Что должно быть здесь ?
            }
            s.Cancel(); //Больше элементы добавляться в очередь не будут
        }
 
        private void Monitor(object token)
        {
            int A;
            try
            {
                while (true)
                {
                    A = queue.Take((CancellationToken)token);
                    MyEvent(A); //Обрабатываем
                }
            }
            catch (OperationCanceledException)
            {
                //Больше элементы добавляться не будут - обрабатываем все что есть и завершаем поток
                while (queue.TryTake(out A))
                {
                    MyEvent(A); //Обрабатываем
                }
            }
        }

public async void DO()
{
  int А =0;
  for(int i = 0;i<10;i++)
  {
   А++;
   await Monitor(A);
  }
}
 
public async  Task Monitor(int A)
{
//  реагирую на изменения А
}

public unsafe async Task<byte*> DO() // НЕ РАБОТАЕТ  Task<byte*> - ОШИБКА
{
   int А =0;
   А++;
   await Monitor(A);
   byte[] b = new byte[5];
   unsafe
  {
     fixed(byte* p = b)
     {
       return p;
      }
   }
}