diff --git a/cmd/lotus-sim/simulation/commit_queue_test.go b/cmd/lotus-sim/simulation/commit_queue_test.go
new file mode 100644
index 000000000..1fee98154
--- /dev/null
+++ b/cmd/lotus-sim/simulation/commit_queue_test.go
@@ -0,0 +1,118 @@
+package simulation
+
+import (
+	"testing"
+
+	"github.com/filecoin-project/go-address"
+	"github.com/filecoin-project/go-state-types/abi"
+	"github.com/filecoin-project/lotus/chain/actors/builtin/miner"
+	"github.com/filecoin-project/lotus/chain/actors/policy"
+	"github.com/stretchr/testify/require"
+)
+
+func TestCommitQueue(t *testing.T) {
+	var q commitQueue
+	addr1, err := address.NewIDAddress(1000)
+	require.NoError(t, err)
+	proofType := abi.RegisteredSealProof_StackedDrg64GiBV1_1
+	require.NoError(t, q.enqueueProveCommit(addr1, 0, miner.SectorPreCommitInfo{
+		SealProof:    proofType,
+		SectorNumber: 0,
+	}))
+	require.NoError(t, q.enqueueProveCommit(addr1, 0, miner.SectorPreCommitInfo{
+		SealProof:    proofType,
+		SectorNumber: 1,
+	}))
+	require.NoError(t, q.enqueueProveCommit(addr1, 1, miner.SectorPreCommitInfo{
+		SealProof:    proofType,
+		SectorNumber: 2,
+	}))
+	require.NoError(t, q.enqueueProveCommit(addr1, 1, miner.SectorPreCommitInfo{
+		SealProof:    proofType,
+		SectorNumber: 3,
+	}))
+	require.NoError(t, q.enqueueProveCommit(addr1, 3, miner.SectorPreCommitInfo{
+		SealProof:    proofType,
+		SectorNumber: 4,
+	}))
+	require.NoError(t, q.enqueueProveCommit(addr1, 4, miner.SectorPreCommitInfo{
+		SealProof:    proofType,
+		SectorNumber: 5,
+	}))
+	require.NoError(t, q.enqueueProveCommit(addr1, 6, miner.SectorPreCommitInfo{
+		SealProof:    proofType,
+		SectorNumber: 6,
+	}))
+
+	epoch := abi.ChainEpoch(0)
+	q.advanceEpoch(epoch)
+	_, _, ok := q.nextMiner()
+	require.False(t, ok)
+
+	epoch += policy.GetPreCommitChallengeDelay()
+	q.advanceEpoch(epoch)
+	_, _, ok = q.nextMiner()
+	require.False(t, ok)
+
+	// 0 : empty + non-empty
+	epoch++
+	q.advanceEpoch(epoch)
+	addr, sectors, ok := q.nextMiner()
+	require.True(t, ok)
+	require.Equal(t, sectors.count(), 2)
+	require.Equal(t, addr, addr1)
+	sectors.finish(proofType, 1)
+	require.Equal(t, sectors.count(), 1)
+	require.EqualValues(t, []abi.SectorNumber{1}, sectors[proofType])
+
+	// 1 : non-empty + non-empty
+	epoch += 1
+	q.advanceEpoch(epoch)
+	addr, sectors, ok = q.nextMiner()
+	require.True(t, ok)
+	require.Equal(t, addr, addr1)
+	require.Equal(t, sectors.count(), 3)
+	require.EqualValues(t, []abi.SectorNumber{1, 2, 3}, sectors[proofType])
+	sectors.finish(proofType, 3)
+	require.Equal(t, sectors.count(), 0)
+
+	// 2 : empty + empty
+	epoch += 1
+	q.advanceEpoch(epoch)
+	_, _, ok = q.nextMiner()
+	require.False(t, ok)
+
+	// 3 : empty + non-empty
+	epoch += 1
+	q.advanceEpoch(epoch)
+	_, sectors, ok = q.nextMiner()
+	require.True(t, ok)
+	require.Equal(t, sectors.count(), 1)
+	require.EqualValues(t, []abi.SectorNumber{4}, sectors[proofType])
+
+	// 4 : non-empty + non-empty
+	epoch += 1
+	q.advanceEpoch(epoch)
+	_, sectors, ok = q.nextMiner()
+	require.True(t, ok)
+	require.Equal(t, sectors.count(), 2)
+	require.EqualValues(t, []abi.SectorNumber{4, 5}, sectors[proofType])
+
+	// 5 : empty + non-empty
+	epoch += 1
+	q.advanceEpoch(epoch)
+	_, sectors, ok = q.nextMiner()
+	require.True(t, ok)
+	require.Equal(t, sectors.count(), 2)
+	require.EqualValues(t, []abi.SectorNumber{4, 5}, sectors[proofType])
+	sectors.finish(proofType, 1)
+	require.EqualValues(t, []abi.SectorNumber{5}, sectors[proofType])
+
+	// 6
+	epoch += 1
+	q.advanceEpoch(epoch)
+	_, sectors, ok = q.nextMiner()
+	require.True(t, ok)
+	require.Equal(t, sectors.count(), 2)
+	require.EqualValues(t, []abi.SectorNumber{5, 6}, sectors[proofType])
+}