code cleanup

Author: msx752

src/SampleDotnet.RepositoryFactory/UnitOfWork.cs

@@ -1,11 +1,10 @@
 using System.Collections.Concurrent;
-using System.Collections.Generic;
 
 namespace SampleDotnet.RepositoryFactory;
 
 internal class UnitOfWork : IUnitOfWork
 {
-    private readonly Queue<DbContextId> _dbContextPool = new();
+    private readonly Queue<DbContextId> _dbContextQueue = new();
     private readonly ConcurrentDictionary<DbContextId, IRepository> _repositoryPool = new();
     private readonly SemaphoreSlim _semaphoreSlim = new(1, 1);
     private readonly IServiceProvider _serviceProvider;
@@ -27,7 +26,7 @@ public IRepository<TDbContext> CreateRepository<TDbContext>(System.Transactions.
             .GetRequiredService<IDbContextFactory<TDbContext>>();
 
         var repository = new Repository<TDbContext>(dbContext, transactionScopeOption, isolationLevel);
-        _dbContextPool.Enqueue(repository.DbContext.ContextId);
+        _dbContextQueue.Enqueue(repository.DbContext.ContextId);
         _repositoryPool.TryAdd(repository.DbContext.ContextId, repository);
         return repository;
     }
@@ -50,8 +49,8 @@ public async Task<bool> SaveChangesAsync(CancellationToken cancellationToken = d
         {
             await _semaphoreSlim.WaitAsync(cancellationToken);
 
-            int count = _dbContextPool.Count;
-            foreach (var dbContextKey in _dbContextPool)
+            int count = _dbContextQueue.Count;
+            foreach (var dbContextKey in _dbContextQueue)
             {
                 if (_repositoryPool.TryGetValue(dbContextKey, out var repo))
                 {
@@ -65,7 +64,7 @@ public async Task<bool> SaveChangesAsync(CancellationToken cancellationToken = d
                     {
                         thrownExceptionDbContext = repo.DbContext;
 
-                        foreach (var dbContextKey2 in _dbContextPool)
+                        foreach (var dbContextKey2 in _dbContextQueue)
                         {
                             if (_repositoryPool.TryGetValue(dbContextKey2, out var repo2))
                             {
@@ -79,12 +78,12 @@ public async Task<bool> SaveChangesAsync(CancellationToken cancellationToken = d
 
             for (int i = 0; i < count; i++)
             {
-                if (_dbContextPool.TryDequeue(out var dbContextKey) && dbContextKey != null)
+                if (_dbContextQueue.TryDequeue(out var dbContextKey) && dbContextKey != null)
                 {
                     if (_repositoryPool.TryRemove(dbContextKey, out var repo))
                     {
                         var newDbContext = repo.RefreshDbContext();
-                        _dbContextPool.Enqueue(newDbContext.ContextId);
+                        _dbContextQueue.Enqueue(newDbContext.ContextId);
                         _repositoryPool.TryAdd(newDbContext.ContextId, repo);
                     }
                 }
@@ -116,7 +115,7 @@ protected virtual void Dispose(bool disposing)
                     }
                 }
 
-                _dbContextPool.Clear();
+                _dbContextQueue.Clear();
                 _semaphoreSlim.Dispose();
             }
             disposedValue = true;

test/SampleDotnet.RepositoryFactory.Tests/Cases/DbContextDisposeTests.cs

@@ -1,10 +1,4 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-
-namespace SampleDotnet.RepositoryFactory.Tests.Cases
+namespace SampleDotnet.RepositoryFactory.Tests.Cases
 {
     public class DbContextDisposeTests
     {

test/SampleDotnet.RepositoryFactory.Tests/_GlobalUsing.cs

@@ -6,5 +6,4 @@
 global using Shouldly;
 global using System.ComponentModel.DataAnnotations;
 global using System.ComponentModel.DataAnnotations.Schema;
-global using System.Transactions;
 global using Xunit;