spin lock自旋锁 双链表操作（多线程安全）（Ring0）

　　通过spin lock自旋锁 ，为每个链表都定义并初始化一个锁，在需要向该链表插入或移除节点时不使用前面介绍的普通函数，而是使用如下方法：
　　ExInterlockedInsertHeadList(&linkListHead, &pData->ListEntry, &spin_lock);

　　//ExInterlockedInsertTailList(&linkListHead, &pData->ListEntry, &spin_lock);
　　ExInterlockedRemoveHeadList(&linkListHead, &spin_lock);

　　此时在向链表中插入或移除节点时会自动调用关联的锁进行加锁操作，有效地保证了多线程安全性。

　　

#include <ntifs.h>


typedef struct _ITEM_ {
    ULONG ItemData;
    LIST_ENTRY ItemEntry;
}ITEM, *PITEM;

VOID SeCreateAtomLock();
VOID RemoveThreadProcedure(PVOID ParameterData);
VOID InsertThreadProcedure(PVOID ParameterData);
VOID DriverUnload(PDRIVER_OBJECT DriverObject);

//bp KAtomLock!DriverEntry
LIST_ENTRY __ListHead;
KSPIN_LOCK __SpinLock;
NTSTATUS DriverEntry(PDRIVER_OBJECT DriverObject, PUNICODE_STRING RegisterPath)
{
    NTSTATUS Status = STATUS_SUCCESS;
    PDEVICE_OBJECT  DeviceObject = NULL;
    
    DriverObject->DriverUnload = DriverUnload;

    //初始化链表
    InitializeListHead(&__ListHead);
    KeInitializeSpinLock(&__SpinLock);
    SeCreateAtomLock();
    
    while (!IsListEmpty(&__ListHead))
    {
        PLIST_ENTRY ListEntry = RemoveTailList(&__ListHead);
        PITEM v1 = CONTAINING_RECORD(ListEntry,
            ITEM,
            ItemEntry);
        KdPrint(("%d
",v1->ItemData));
        ExFreePool(v1);
    }
    return Status;
}
VOID SeCreateAtomLock()
{
    HANDLE  ThreadHandle[2] = { 0 };
    ULONG   i = 0;
    PVOID   ThreadObject[2] = { 0 };
    PsCreateSystemThread(&ThreadHandle[0], 0, NULL, NULL, NULL, InsertThreadProcedure,NULL);
    PsCreateSystemThread(&ThreadHandle[1], 0, NULL, NULL, NULL, RemoveThreadProcedure,NULL);
    for (i = 0; i < 2; i++)
    {
        ObReferenceObjectByHandle(ThreadHandle[i], 0, NULL, KernelMode, &ThreadObject[i], NULL);
    }
    KeWaitForMultipleObjects(2, ThreadObject, WaitAll, Executive, KernelMode, FALSE, NULL, NULL);
    for (i = 0; i < 2; i++)
    {
        ObDereferenceObject(ThreadObject[i]);
        ZwClose(ThreadHandle[i]);
        ThreadHandle[i] = NULL;
    }
}
VOID DriverUnload(PDRIVER_OBJECT DriverObject)
{
    DbgPrint("DriverUnload()
");
}

VOID InsertThreadProcedure(PVOID ParameterData)
{
    PITEM Item;
    int Count = 0;

    
    for (Count = 1; Count <= 20; Count += 1)
    {    
        DbgPrint("InsertThreadProcedure()
");
        Item = (PITEM)
            ExAllocatePool(PagedPool, sizeof(ITEM));   //分页内存 
        Item->ItemData = Count;
        //ExInterlockedInsertTailList              插入双向链表互锁操作  
        ExInterlockedInsertHeadList(&__ListHead, &Item->ItemEntry,&__SpinLock);
    }
    PsTerminateSystemThread(STATUS_SUCCESS);

}

VOID RemoveThreadProcedure(PVOID ParameterData)
{
    
    int Count = 0;
    for (Count = 1; Count <= 10; Count += 1)
    {
        DbgPrint("RemoveThreadProcedure()
");
        PLIST_ENTRY ListEntry = ExInterlockedRemoveHeadList(&__ListHead,&__SpinLock);
        PITEM v1 = CONTAINING_RECORD(ListEntry,
            ITEM,
            ItemEntry);
        ExFreePool(v1);
    }
    PsTerminateSystemThread(STATUS_SUCCESS);

}