chore: Add processor dispose validation test

Author: jeromelaban

src/OpenTelemetry/Internal/BatchExportTaskWorker.cs

@@ -180,6 +180,10 @@ await Task.WhenAny(
                     this.shutdownCompletionSource.Task,
                     Task.Delay(timeout, combinedTokenSource.Token)).ConfigureAwait(false);
             }
+            catch (ObjectDisposedException)
+            {
+                return false; // The worker has been disposed
+            }
             catch (OperationCanceledException)
             {
                 // Expected when timeout or shutdown occurs
@@ -216,13 +220,13 @@ await Task.WhenAny(
                     }
                     catch (OperationCanceledException)
                     {
-                        if (this.isShutdownRequested)
-                        {
-                            break;
-                        }
-
                         // Continue to check if there's data to export before exiting
                     }
+                    catch (ObjectDisposedException)
+                    {
+                        // the exporter is somehow disposed before the worker thread could finish its job
+                        return;
+                    }
                 }
 
                 this.PerformExport();

test/OpenTelemetry.Tests/Logs/BatchLogRecordExportProcessorTests.cs

@@ -154,5 +154,44 @@ public void LogRecordAddedToBatchIfNotFromAnyPoolTest()
         Assert.Single(exportedItems);
         Assert.Same(logRecord, exportedItems[0]);
     }
+
+    [Theory]
+    [InlineData(true)]
+    [InlineData(false)]
+    public void DisposeWithoutShutdown(bool useThread)
+    {
+        var scopeProvider = new LoggerExternalScopeProvider();
+
+        List<LogRecord> exportedItems = new();
+
+        var processor = new BatchLogRecordExportProcessor(
+#pragma warning disable CA2000 // Dispose objects before losing scope
+            new InMemoryExporter<LogRecord>(exportedItems),
+#pragma warning restore CA2000 // Dispose objects before losing scope
+            useThreads: useThread,
+            maxQueueSize: BatchLogRecordExportProcessor.DefaultMaxQueueSize,
+            maxExportBatchSize: BatchLogRecordExportProcessor.DefaultMaxExportBatchSize,
+            exporterTimeoutMilliseconds: BatchLogRecordExportProcessor.DefaultExporterTimeoutMilliseconds,
+            scheduledDelayMilliseconds: int.MaxValue);
+
+        processor.Dispose();
+
+        using var scope = scopeProvider.Push(exportedItems);
+
+        var pool = LogRecordSharedPool.Current;
+
+        var logRecord = pool.Rent();
+
+        var state = new LogRecordTests.DisposingState("Hello world");
+
+        logRecord.ILoggerData.ScopeProvider = scopeProvider;
+        logRecord.StateValues = state;
+
+        processor.OnEnd(logRecord);
+
+        state.Dispose();
+
+        Assert.Empty(exportedItems);
+    }
 }
 #endif