AsyncTask

AsyncTask系统实现的多线程与自己实现继承的FRunnable实现的原理相似，还可以利用UE4提供的线程池。当使用多线程不满意时也可以调用StartSynchronousTask改成主线程执行。

来自头文件 AysncWork.h 文件中注释，直接仿照注释来实现AsyncTask

/**
    FAutoDeleteAsyncTask - template task for jobs that delete themselves when complete

    Sample code:

    class ExampleAutoDeleteAsyncTask : public FNonAbandonableTask
    {
        friend class FAutoDeleteAsyncTask<ExampleAutoDeleteAsyncTask>;

        int32 ExampleData;

        ExampleAutoDeleteAsyncTask(int32 InExampleData)
         : ExampleData(InExampleData)
        {
        }

        void DoWork()
        {
            ... do the work here
        }

        FORCEINLINE TStatId GetStatId() const
        {
            RETURN_QUICK_DECLARE_CYCLE_STAT(ExampleAutoDeleteAsyncTask, STATGROUP_ThreadPoolAsyncTasks);
        }
    };

    
    void Example()
    {
        // start an example job
        (new FAutoDeleteAsyncTask<ExampleAutoDeleteAsyncTask>(5)->StartBackgroundTask();

        // do an example job now, on this thread
        (new FAutoDeleteAsyncTask<ExampleAutoDeleteAsyncTask>(5)->StartSynchronousTask();
    }

**/

代码实现：

继承FNonAbandonableTask创建一个线程类

在DoWork中实现需要实现的功能

// FTestAsyncTask.h

  #include “Async\AsyncWork.h”
  #include “CoreMinimal.h”

class MX_API FTestAsyncTask : public FNonAbandonableTask
{
public:
    friend class FAutoDeleteAsyncTask<FTestAsyncTask>;
    int32 RunCount = 0;

    FTestAsyncTask(FString ThreadName,class AActor1* a1) : MyThreadName(ThreadName), A1(a1) {};
    ~FTestAsyncTask();

    void DoWork();

    FORCEINLINE TStatId GetStatId() const
    {
        RETURN_QUICK_DECLARE_CYCLE_STAT(FTestAsyncTask, STATGROUP_ThreadPoolAsyncTasks);
    }

    FString MyThreadName;
    class AActor1* A1;
    static FCriticalSection CriticalSection;
};
///////////////////////////////////////////////////////////////////////
// FTestAsyncTask.cpp 
FCriticalSection FTestAsyncTask::CriticalSection;

FTestAsyncTask::~FTestAsyncTask()
{

}

void FTestAsyncTask::DoWork()
{
    UE_LOG(LogTemp, Log, TEXT("%s------%d"), *MyThreadName, RunCount);
    while (IsValid(A1)) {
        // 同步锁
        FScopeLock Lock(&CriticalSection);
        if (A1->TestCount < A1->TestTarget)
        {
            A1->TestCount++;
            RunCount++;
            // 节约资源 每100次打印一次
            if (RunCount % 100 == 0)
                UE_LOG(LogTemp, Log, TEXT("%s======%d"), *MyThreadName, RunCount);
        }
        else
        {
            break;
        }
    }
    
}

执行线程类：

// 头文件
    int32 TestCount;

    UPROPERTY(EditAnywhere)
        int32 TestTarget;
// 线程运行
    (new FAutoDeleteAsyncTask<FTestAsyncTask>("thread1", this))->StartBackgroundTask();
    (new FAutoDeleteAsyncTask<FTestAsyncTask>("thread2", this))->StartBackgroundTask();

在自定义执行的线程类中 使用 FAutoDeleteAsyncTask 来传入我们刚才写的Task。FAutoDeleteAsyncTask顾名思义就是任务执行完就会自动删除。

还有StartBackgroundTask和StartSynchronousTask的区别：

  • StartBackgroundTask会利用线程池里空闲的线程来执行。
  • StartSynchronousTask则是主线程执行。

执行结果：

 这里运行次数设置的为100000 缺少一次是因为当满足条件是直接跳出了，没有打印出

 

原文地址：http://www.cnblogs.com/limu-zy/p/16816335.html

1. 本站所有资源来源于用户上传和网络，如有侵权请邮件联系站长！ 2. 分享目的仅供大家学习和交流，请务用于商业用途! 3. 如果你也有好源码或者教程，可以到用户中心发布，分享有积分奖励和额外收入！ 4. 本站提供的源码、模板、插件等等其他资源，都不包含技术服务请大家谅解！ 5. 如有链接无法下载、失效或广告，请联系管理员处理！ 6. 本站资源售价只是赞助，收取费用仅维持本站的日常运营所需！ 7. 如遇到加密压缩包，默认解压密码为"gltf",如遇到无法解压的请联系管理员！ 8. 因为资源和程序源码均为可复制品，所以不支持任何理由的退款兑现，请斟酌后支付下载 声明：如果标题没有注明"已测试"或者"测试可用"等字样的资源源码均未经过站长测试.特别注意没有标注的源码不保证任何可用性