Исходная идея: вынести физическое взаимодействие с БД в отдельный фоновый поток. А в основном потоке работаем только с DataSet и DataTable. Метод, работающий в фоне, в бесконечном цикле периодически проверяет состояние всех таблиц в DataSetе и если есть изменения – отражает их в БД, после чего «засыпает» на некоторое время.

Что потребуется для работы:
- DataSet – собственно в нем данные
- OleDbDataAdapter – «мостик» между приложением и БД
- OleDbCommandBuilder – генерирует соответствующие SQL-команды для передачи в БД

Дабы не загромождать код примера будем считать, что переменные этих типов уже объявлены в программе и доступны нашему классу:

Friend DBConnection As New OleDbConnection()
Friend DBds As DataSet
Friend DBAdapter As OleDbDataAdapter
Friend DBCommandBuilder As New OleDbCommandBuilder(DBAdapter)

Imports System.Threading
Imports System.Data.OleDb
Public Class DataUpdater
	Private m_sleeper As Integer время на которое засыпает поток, в миллисекундах
	Private m_continue As Boolean переменная для принудительного завершения цикла
Private m_paused As Boolean переменная для временной приостановки цикла
Private aTable As DataTable переменная для перебора таблиц
	Private TempTable As DataTable таблица для временного хранения данных
Event TableUpdate(ByVal aTableName As String) событие генерируется после успешного 
 обновления данных из одной таблицы
 Property Paused() As Boolean
 Get
 Return m_paused
 End Get
 Set(ByVal Value As Boolean)
 m_paused = Value
 End Set
 End Property
 Property Continue() As Boolean
 Get
 Return m_continue
 End Get
 Set(ByVal Value As Boolean)
 m_continue = Value
 End Set
 End Property
 Property Sleeper() As Integer
 Get
 Return m_sleeper
 End Get
 Set(ByVal Value As Integer)
 m_sleeper = Value
 End Set
 End Property
End Class

Friend Sub DoWork()
 Do While m_continue
 If Not m_paused Then
 For Each aTable In DBds.Tables
 TempTable = aTable.GetChanges()
 If Not TempTable Is Nothing Then UpdateOneTable(aTable)
 Next
 End If
 Thread.Sleep(m_sleeper)
 Loop
End Sub

Теперь о процедуре UpdateOneTable. Вот ее код:

Friend Sub UpdateOneTable(ByRef onetable As DataTable)
 AddHandler DBAdapter.RowUpdated, New OleDbRowUpdatedEventHandler(AddressOf OnRowUpdated)
 Try
 DBAdapter.SelectCommand.CommandType = CommandType.TableDirect
 DBAdapter.SelectCommand.CommandText = onetable.TableName
 DBCommandBuilder.RefreshSchema()
 DBAdapter.InsertCommand = DBCommandBuilder.GetInsertCommand
 DBAdapter.UpdateCommand = DBCommandBuilder.GetUpdateCommand
 DBAdapter.DeleteCommand = DBCommandBuilder.GetDeleteCommand
 DBAdapter.Update(onetable)
 onetable.AcceptChanges()
 RaiseEvent TableUpdate(onetable.TableName)
 Catch ex As Exception
 MsgBox("При сохранении данных в таблице " & _
 onetable.TableName & " возникла следующая ошибка:" & vbCrLf & vbCrLf & _
 ex.Message & vbCrLf & vbCrLf, MsgBoxStyle.Critical)
 onetable.RejectChanges()
 End Try
 RemoveHandler DBAdapter.RowUpdated, New OleDbRowUpdatedEventHandler(AddressOf OnRowUpdated)
End Sub

Private Shared Sub OnRowUpdated(ByVal sender As Object, ByVal args As OleDbRowUpdatedEventArgs)
 Include a variable and a command to retrieve the identity value from the Access database.
 Dim newID As Integer = 0
 Dim idCMD As OleDbCommand = New OleDbCommand("SELECT @@IDENTITY", DBConnection)
 If args.StatementType = StatementType.Insert Then
 Retrieve the identity value and store it in the CategoryID column.
 newID = CInt(idCMD.ExecuteScalar())
 args.Row("s_thisID") = newID
 MsgBox("New ID is " & newID)
 End If
End Sub

Создаем экземпляр класса:

Friend WithEvents anUpdater As New DataUpdater()

With anUpdater
 .Continue = True
 .Paused = False
 .Sleeper = 250 выполняем проверку 4 раза в секунду
End With
Dim thr As New Threading.Thread(AddressOf anUpdater.DoWork)
With thr
 .IsBackground = True поток завершится сам при завершении приложения
 .Name = "Updaterthread"
 .Start()
End With