SqlDependency с использованием BackgroundWorker

У меня есть таблица в базе данных SQL Server, которая представляет файл журнала некоторых действий, вставленных из работающей службы Windows. Все работает хорошо.

Но у меня есть приложение Windows, которое получает последние строки, вставленные в таблицу журнала, и просматривает их в файле DataGridView. При разработке этого приложения я полагался на Использование SqlDependency в приложении Windows из MSDN. Он работает хорошо, но когда таблица журнала получает большое количество сведений журнала, приложение Windows зависает, а основной пул потоков становится слишком занятым.

Я хочу запустить тот же код, указанный в предыдущей ссылке, в отдельном пуле потоков, используя класс Thread или элемент управления BackgroundWorker. Это означает поток для использования элементов управления пользовательского интерфейса и еще один для прослушивания изменений в базе данных и передачи их в файл DataGridView.

Вы можете увидеть скриншот пользовательского интерфейса по этой ссылке "UI"

№ (1): этот GroupBox представляет инструменты пользовательского интерфейса, которые пользователи могут использовать во время мониторинга.

№ (2): Кнопка Старт отвечает за начало прослушивания и получения обновлений из базы данных, а также за пополнение DataGridView.

№ (3): Эта сетка представляет новые журналы, которые были вставлены в базу данных.

№ (4): это число (38 изменений) представляет количество прослушиваний зависимости sql от изменений в базе данных.

Мой код: общедоступный частичный класс frmMain : Form { SqlConnection conn;

    const string tableName = "OutgoingLog";
    const string statusMessage = "{0} changes have occurred.";
    int changeCount = 0;

    private static DataSet dataToWatch = null;
    private static SqlConnection connection = null;
    private static SqlCommand command = null;

    public frmMain()
    {
        InitializeComponent();
    }

    private bool CanRequestNotifications()
    {
        // In order to use the callback feature of the
        // SqlDependency, the application must have
        // the SqlClientPermission permission.
        try
        {
            SqlClientPermission perm = new SqlClientPermission(PermissionState.Unrestricted);

            perm.Demand();

            return true;
        }
        catch
        {
            return false;
        }
    }

    private void dependency_OnChange(object sender, SqlNotificationEventArgs e)
    {
        // This event will occur on a thread pool thread.
        // Updating the UI from a worker thread is not permitted.
        // The following code checks to see if it is safe to
        // update the UI.
        ISynchronizeInvoke i = (ISynchronizeInvoke)this;

        // If InvokeRequired returns True, the code
        // is executing on a worker thread.
        if (i.InvokeRequired)
        {
            // Create a delegate to perform the thread switch.
            OnChangeEventHandler tempDelegate = new OnChangeEventHandler(dependency_OnChange);

            object[] args = { sender, e };

            // Marshal the data from the worker thread
            // to the UI thread.
            i.BeginInvoke(tempDelegate, args);

            return;
        }

        // Remove the handler, since it is only good
        // for a single notification.
        SqlDependency dependency = (SqlDependency)sender;

        dependency.OnChange -= dependency_OnChange;

        // At this point, the code is executing on the
        // UI thread, so it is safe to update the UI.
        ++changeCount;
        lblChanges.Text = String.Format(statusMessage, changeCount);
        this.Refresh();

        // Reload the dataset that is bound to the grid.
        GetData();
    }

    private void GetData()
    {
        // Empty the dataset so that there is only
        // one batch of data displayed.
        dataToWatch.Clear();

        // Make sure the command object does not already have
        // a notification object associated with it.
        command.Notification = null;

        // Create and bind the SqlDependency object
        // to the command object.
        SqlDependency dependency = new SqlDependency(command);

        dependency.OnChange += new OnChangeEventHandler(dependency_OnChange);

        using (SqlDataAdapter adapter = new SqlDataAdapter(command))
        {
            adapter.Fill(dataToWatch, tableName);

            dgv.DataSource = dataToWatch;
            dgv.DataMember = tableName;
            dgv.FirstDisplayedScrollingRowIndex = dgv.Rows.Count - 1;
        }
    }

    private void btnStart_Click(object sender, EventArgs e)
    {
        changeCount = 0;
        lblChanges.Text = String.Format(statusMessage, changeCount);

        // Remove any existing dependency connection, then create a new one.
        SqlDependency.Stop("<my connection string>");
        SqlDependency.Start("<my connection string>");

        if (connection == null)
        {
            connection = new SqlConnection("<my connection string>");
        }

        if (command == null)
        {
            command = new SqlCommand("select * from OutgoingLog", connection);
        }

        if (dataToWatch == null)
        {
            dataToWatch = new DataSet();
        }

        GetData();
    }

    private void frmMain_Load(object sender, EventArgs e)
    {
        btnStart.Enabled = CanRequestNotifications();
    }

    private void frmMain_FormClosing(object sender, FormClosingEventArgs e)
    {
        SqlDependency.Stop("<my connection string>");
    }
}

Что именно я хочу: когда пользователь нажимает кнопку Пуск, приложение запускает код в отдельном пуле потоков.