Блог

Я использую поток для запуска общедоступной функции класса. Проблема в том, что только если установлена точка останова внутри функции потока (общедоступная функция класса), она вызывается иначе, вызывая поток.Запуск не оказывает никакого эффекта. После вызова функции потока она успешно завершается, давая желаемые результаты.

  QueueProcessor     processor  = null;
 Thread subprocess =null;

 public void processQueue()
 {
    if (processor == null)
    {         
        processor = new QueueProcessor();
    }

    if (subprocess == null)
    {                                            
        subprocess = new Thread(processor.run);
        subprocess.IsBackground = true;
    }

    if (!subprocess.IsAlive)
    {                
        subprocess.Start();                                
    }
    else
    {          
    }
} 

class QueueProcessor
{       
    public QueueProcessor()
    {           
        instance = new RecordDao();
        service = new CommonsService();
    }

    public void run()
    {
        startProcessing(); // it won't reach here unless a breakpoint is set.
    }

    public bool startProcessing()
    {
        //some database routines here.

       // some web service calls here
    }
}
  

Пожалуйста, помогите.

РЕДАКТИРОВАТЬ: теперь, когда вы изменили код, есть две проблемы:

1. Вы потенциально пытаетесь перезапустить поток, если вы когда-либо вызываете processQueue после завершения обработки. Вы не можете этого сделать.

2. Если processQueue вызывается из нескольких потоков, у вас возникают проблемы с потенциальным запуском нескольких потоков из-за условий гонки, а также потенциальных проблем с моделью памяти.

Первый пункт проще решить с помощью:

 if (subprocess == null || !subprocess.IsAlive)
{                                            
    subprocess = new Thread(processor.run);
    subprocess.IsBackground = true;
    subprocess.Start();
}
  

… но это все еще оставляет потенциальную проблему второго пункта. Что такое вызов processQueue ? Это всегда один и тот же поток? (И почему вы игнорируете.Соглашения об именовании сетей?)

Я предполагаю, что то, что вы видите, на самом деле обработка происходит ровно один раз, но нет никакой работы, и будущие вызовы не перезапускают поток, как предположительно вы ожидали, — тогда как, если у вас есть точка останова, то к тому времени, когда вы снова нажмете «перейти», есть над чем поработать. На предположение … конечно, запуск потока работает без точек останова, поэтому недостаток где-то в вашем коде. Если бы вы могли создать короткую, но полную программу, которая демонстрирует проблему, мы могли бы разобраться в ней.

 Main thread                  New thread status

                             Not started...

Check: IsAlive == false

                             Still not started...

Check: IsAlive == false

                             Starting!
                             Call startProcessing...
                             startProcessing completes...
                             Finished

Check: IsAlive == false