C # - Thread.Join (миллисекунды) и блок finally - PullRequest
1 голос
/ 30 октября 2010

Я использую .NET 2.0, и, кажется, блок finally не выполняется, если истекает время ожидания потока.Например, если я вижу сообщение «Дочерняя тема истекла ...», я не вижу сообщения «Наконец, блок начался ...».Это означает, что объекты базы данных (Oracle.DataAccess) могут не очищаться должным образом.Есть ли способ принудительной очистки внутри дочернего потока, или ее следует перенести в основной поток и передать объекты базы данных в дочерний поток?

   private void runThread(string strSP, object objThreadParameter)
    {
        try
        {
            bool blnThreadCompletedOK = true;

            Thread threadHelper = new Thread(getData);
            threadHelper.Start(objThreadParameter);

            // Wait for called thread.  
            blnThreadCompletedOK = threadHelper.Join(THREAD_TIMEOUT);
            if (blnThreadCompletedOK)
            {
                // Thread has completed and should have stopped running.
                // i.e. the thread has processed normally or an exception has been copied to the objExceptionThread object.
                if (objExceptionThread != null)
                {
                    throw objExceptionThread;
                }
            }
            else
            {
                System.Diagnostics.EventLog.WriteEntry("Main thread", "Child Thread Timed Out...", System.Diagnostics.EventLogEntryType.Warning);

                // Main thread has timed out waiting for the child thread.  Likely the child thread is still running.
                if (threadHelper.IsAlive)
                {
                    threadHelper.Abort();  // This will trigger the exception handling in the child thread and cause the finally
                                           // block to be executed.
                }
                throw (new Exception("The call to " + strSP + "() timed out as it exceeded " + (THREAD_TIMEOUT / 1000).ToString() + " seconds"));
            }
        }
        catch (Exception exc)
        {
            throw new PivotalApplicationException(exc.Message, exc, mrsysSystem);
        }
    }


    private void getData(object objThreadParameter)
    {
        OracleCommand oraCmd = null;
        OracleConnection oraConn = null;
        OracleDataReader dr = null;

        try
        {              
            // Initialization.
            int intMAX_RETRIES = 20;       // Maximum number of retries.
            int intRETRY_DROP_POOL = 5;    // At some point, if connections are still failing, try clearing the pool.

            // Other initialization stuff...

            // Now execute the SP.
            for (int i = 1; i <= intMAX_RETRIES; i++)
            {
                try
                {
                    try
                    {
                        // Setup Oracle connection and initialize Oracle command object.
                        getOracleConnection(out oraConn, connString);
                    }
                    catch (Exception exc)
                    {
                        throw new Exception("Error in getData() setting up connection - " + exc.Message);
                    }

                    try
                    {
                        oraCmd = new OracleCommand(strSP, oraConn);
                        setupCommand (out oraCmd);
                    }
                    catch (Exception exc)
                    {
                        throw new Exception("Error in getData() setting up parameters - " + exc.Message);
                    }

                    try
                    {
                        dr = oraCmd.ExecuteReader();
                        break; // Success, so, leave the for loop.
                    }
                    catch (Exception exc)
                    {
                        throw new Exception("Error in getData() executing command.\n\n" + strParametersMsg + " \n\n" + exc.Message);
                    }
                }
                catch (Exception excInner)
                {

                    if (i >= intMAX_RETRIES)
                    {
                        throw new Exception(excInner.Message);
                    }
                    else
                    {
                        // Cleanup oraCmd, oraConn, oraDr...
                    }
                }
            }

            try
            {
                // Process results...
            }
            catch (Exception exc)
            {
                throw new Exception("Error in getData() processing results - " + exc.Message);
            }

            // Now set the variables that are shared between the Main thread and this thread...

        }
        catch (Exception exc)
        {
            logMessage(exc.Source + " " + exc.Message);
            objExceptionThread = exc;  // Initialize exception in Main Thread...
        }
        finally
        {
            System.Diagnostics.EventLog.WriteEntry("Child Thread", "Finally block started...", System.Diagnostics.EventLogEntryType.Warning);

            // With .NET 2.0 and later, the finally block should always be executed correctly for a Thread.Abort()
            if (!(dr == null))
            {
                dr.Dispose();
            }
            if (!(oraCmd == null))
            {
                oraCmd.Dispose();
            }
            if (!(oraConn == null))
            {
                oraConn.Close();
                oraConn.Dispose();
            }

            System.Diagnostics.EventLog.WriteEntry("Child Thread", "Finally block completed...", System.Diagnostics.EventLogEntryType.Warning);
        }
    }

Ответы [ 3 ]

2 голосов
/ 30 октября 2010

Вы должны прервать поток, только если этот поток больше ничего не делает.В других случаях я бы рекомендовал установить какое-то уведомление (например, установить логическое свойство потока), которое заставит ваш поток корректно завершить работу.Сказав, что согласно документации блок finally должен выполняться в .NET 2.0:

Когда вызывается метод Abort для уничтоженияпоток, общеязыковая среда выполнения создает исключение ThreadAbortException.ThreadAbortException - это особое исключение, которое может быть перехвачено, но оно будет автоматически вызвано снова в конце блока catch.Когда возникает это исключение, среда выполнения выполняет все блоки finally перед окончанием потока.

Лучшее предположение относительно того, что происходит, заключается в том, что основной поток завершает работу до того, как блок finally в вашем потоке имеетшанс быть казненным.Попробуйте вставить Thread.Sleep после прерывания потока, чтобы увидеть, изменит ли это поведение.

Редактировать: я написал простой пример с .NET 2.0, который выдает следующий вывод, показывающий, что блок finally выполняется.

Жив и кайф

Жив и кайф

Жив и кайф

Исключение

Наконец

class ThreadTest
{
    public ThreadTest() { }

    public void test()
    {
        try
        {
            while (true)
            {
                Console.WriteLine("Alive and kicking");
                Thread.Sleep(2000);
            }
        }

        catch (Exception ex)
        {
            Console.WriteLine("Exception");
        }

        finally
        {
            Console.WriteLine("Finally");

        }
    }
}
class Program
{
    static void Main(string[] args)
    {
        ThreadTest myThreadTest = new ThreadTest();
        Thread myThread = new Thread(new ThreadStart(myThreadTest.test));
        myThread.Start();
        Thread.Sleep(5000);
        bool status = myThread.Join(1000);
        if (myThread.IsAlive)
        {
            myThread.Abort();
        }
        Thread.Sleep(5000);
    }
}
1 голос
/ 30 октября 2010

Вы можете прерывать поток, только когда он находится в управляемом коде. Если он находится в собственном коде, тогда среда выполнения планирует ThreadAbortException, который будет выдан при возврате собственного кода. И finally блоки будут выполняться после этого. Блок finally не будет выполняться до тех пор, пока не будет возвращена нативная функция и возобновится управляемое выполнение.

Если ваша проблема в том, что собственный код завис, то блок finally не может быть запущен.

0 голосов
/ 30 октября 2010

Спасибо. Проблема, похоже, связана с синхронизацией. Если я неоднократно проверяю свойство threadHelper.IsAlive и продолжаю работу основного потока, блок finally действительно выполняется. Итак, я думаю, что код висит на dr = oraCmd.ExecuteReader (); Thread.Join () возвращает, пытается Abort () - но не может в это время, а затем основной поток заканчивается, поэтому дочерние потоки также уничтожаются. Я думаю, что это оставляет открытое соединение, хотя.

Предполагается, что ODP.NET является поставщиком управляемых данных (http://wiki.oracle.com/page/Oracle+Data+Provider+for+.Net), и у него также есть свойство тайм-аута команды.

«CommandTimeout Определяет количество секунд, в течение которых команде разрешено выполнять перед тем, как прекратить выполнение с исключением».

Я еще выясню, почему CommandTimeout, похоже, не соблюдается, и если это по-прежнему не удается, я могу попробовать Завершение доменов приложений для человека, который, кажется, имеет все книги.

http://www.albahari.com/threading/part4.aspx#_Aborting_Threads

Спасибо за помощь!

...