如何设置线程优先级 delphi

Posted 2023-04-12

复制一篇Delphi TThread中文注释帮助文档给你，希望对你有帮助。

delphi 的 TThread是一个抽象类，可以创建几个独立的线程。

类关系 TObject

在一个多线程的应用程序中创建一个TThread的后子类代表一个线程。每一新子类的TThread对象的实例是一个新的线程。从TThread派生的多线程实例可以构成Delphi的多线程应用程序。

当一个应用程序运行时，应用程序就被载入内存准备执行。此时，它成为包含一个或多个线程的进程，每个线程含有数据、代码和系统资源。线程执行应用程序的部分内容，并由系统分配CPU时间。同一进程的所有线程共享同一地址空间，可以访问进程的全局变量。线程通过以下工作改善应用的性能：管理多通信设备的输入。

区分任务的优先级。优先级高的处理紧急的任务。优先级低的处理其他任务。

以下是使用线程的一些建议：

同时跟踪太多的线程消耗CPU时间。对单处理器系统，一个进程最多有16个线程。

当多个线程更新相同的资源时，应使线程同步以避免冲突。

大多数访问VCL对象和更新窗体的方法必须从主VCL线程内部调用。

以下为创建和使用一个新线程的过程：

（1）单击File|New|Thread菜单项，创建一个包含对象的新单元，该对象源于TThread类。

（2）定义新线程对象和Create方法。

（3）通过插入线程执行时需要的代码定义线程对象和Execute方法。

（4）将使用VCL组件的任何调用传递给Synchronize方法，以避免多线程冲突。

属性列表

FreeOnTerminate 线程终止时该对象是否自动删除

Handle 包含线程句柄

Priority 确定该线程相对于进程中其他线程的优先级

ReturnValue 返回线程值

Suspended 指示一线程是否被挂起

Terminated 表明线程被要求终止

ThreadID 标识贯穿系统的线程

方法列表

~TThread 删除线程对象并释放其战用的内存空间

DoTerminate 产生一个OnTerminate事件

Execute 提供包含线程执行时所需代码的抽象方法

Resume 重新执行一个挂起的线程

Suspend 挂起一个运行中的线程

Synchronize 在主VCL线程中执行Method

Terminate 将Ternimated属性设置为True通知线程终止

TThread 创建一个线程对象的实例

WaitFor 等待线程终止并返回ReturnValue属性值

事件列表

OnTerminateExecute 方法已返回且该线程被删除前发生

属性

TThread::FreeOnTerminate

__property bool FreeOnTerminate = read=FFreeOnTerminate,write=FFreeOnTerminate,nodefault;

确定当线程终止时，该线程对象是否自动删除。

FreeOnTerminate默认值为False，线程对象必须在代码中显示删除。

包含线程句柄。

当调用Win32API函数处理线程时，使用Handle.

TThread::Priority

__property TThreadPriority Priority = read=GetPriority,write=SetPriority,nodefault;

确定该线程相对于进程中其他线程的优先级。

Priority属性为一枚举类型，其默认为tpNormal.

TThreadPriority类型定义了TThread组件的Priority属性的可能值，如下表所述。Windows根据优先级确定每一个线程的CPU周期。

_____________________________________________________________________

值 含义

_____________________________________________________________________

tpIdle 只有当系统空闲时该线程执行

tpLowest 线程优先级比正常低2点

tpLower 线程优先级比正常低1点

tpNormal 线程优先级为正常值

tpHigher 线程优先级比正常高1点

tpHighest 线程优先级比正常高2点

tpTimeCritical 线程优先级最高

TThread::ReturnValue

__property int ReturnValue = read=FReturnValue,write=FReturnValue,nodefault;

返回线程值。

使用ReturnValue应用为其他线程指示其成功/失败或数字结果/输出。WaitFor方法返回存储在ReturnValue中的值。

TThread::Suspended

__property bool Suspended = read=FSuspended,write=SetSuspended,nodefault;

指示一线程是否被挂起。

除非重新执行，否则被挂起的线程不会继续执行。若将Suspended设置为True将挂起一个线程；若设置为False,则继续执行该线程。

TThread::Terminated

__property bool Terminated = read=FTerminated,nodefault;

表明线程被要求终止。Terminate方法将Terminated属性设置为True。

线程的Execute方法和任何Execute调用的方法将周期性地检查Terminated，当其为True时，将终止执行。

TThread::ThreadID

__property int ThreadID = read=FhreadID,nodefault;

标识贯穿系统的线程。

当调用Win32API函数处理线程时，ThreadID将十分有用。

注意：ThreadID与Handle属性不同。

方法

TThread::~TThread

__fastcall virvual ~TThread(void);

删除线程对象并释放其战胜的内存空间。

在应用中不要调用~TThread。用delete替代。

~TThread通知线程终止，并在调用Destroy方法前等待该线程返回。

TThread::DoTerminate

virtual void __fastcall DoTerminate(void);

产生一个OnTerminate事件。

DoTerminate调用OnTerminate时间句柄，但并不终止该线程。

TThread::Execute

virtual void __fastcall Execute(void) =0;

提供包含线程执行时所需代码的抽象方法。

Execute查看Terminated属性值以决定该线程是否需要终止。

当CreateSuspended被设置为False，当调用Create时，一线程执行；在线程创建后先调用了Resume且CreateSuspended为True，一线程执行。

注意：不要在线程的Execute方法中直接调用

其他对象的属性和方法。应该将对其他对象的使用分成几个不同的过程，将其作为一个传递到Synchronize方法的参数分别调用。

TThread::Resume

void __fastcall Resume(void);

重新执行一个挂起的线程。

调用Suspend可以嵌套。因此调用Resume必须注意次序。

TThread::Suspend

void __fastcall Suspend(void);

挂起一个运行中的线程。

调用Resume可以继续运行。调用Suspend可以嵌套。因此调用Resume必须次序。

TThread::Synchronize

typedef void __fastcall(__closure* TThreadMethod)(void);

void __fastcall Synchronize (TThreadMethod&Method);

在主VCL线程中执行Method。

Synchronize方法由Method指定的调用被主VCL线程执行。

注意：当在主VCL线程中执行Method时，当前的线程被挂起。

TThread::Terminate

void __fastcall Terminate(void);

通过将Terminated属性设置为True通知线程终止。

线程的Execute方法以及Execute调用的任何方法应周期性的检查Terminated，当其为True时终止运行。

TThread::TThread

__fastcall TThread(bool CreateSuspended);

创建一个线程对象的实例。

在应用中不要直接使用TThread来创建线程。用new替代，传递CreateSuspended参数argument。若CreateSuspended为False,Execute被立即调用。若CreateSuspended为True,Execute直到Resume被调用后才被调用。

TThread::WaitFor

int __fastcall WaitFor(void);

等待线程终止并返回ReturnValue属性值。

直到线程终止时WaitFor才返回，因此线程一定是因为结束了Execute方法或因Terminated属性为了True而终止。如果该线程使用Synchronize,则不要在主VCL线程中调用WaitFor，否则或者引起系统死机，或者产生一个EThread异常。

Synchronize在允许该方法生效前等待主VCL线程进入信息回路。若主VCL线程已经调用了WaitFor,它将不会进入信息回路，Synchronize也永远不会返回。此时，TThread将产生一个EThread意外并使该线程终止；而且如果该意外没有被Execute方法截获，该应用也将终止。如果调用WaitFor时，Synchronize已经在VCL线程中等待，TThread将不会干预，应用程序将死机。

事件

TThread::OnTerminate

__property TNotifyEvent OnTerminate = read=FOnTerminate,write=FOnTerminate;

当线程的Execute方法已经返回且在该线程被删除之前发生。

OnTerminate事件句柄在主VCL线程被调用。该线程对象也可在该事件中被释放。 参考技术A Tthread有个Priority属性，是指定线程优先级的。具体自己看帮助。

pthread_setschedparam（设置线程的优先级）

 在linux下我们可以通过

int pthread_create(pthread_t *thread, const pthread_attr_t *attr,
    void *(*start_routine)(void*), void *arg);
来创建线程，但是如何设置线程的优先级呢？
在讨论这个问题的时候，我们先要确定当前线程使用的调度策略，posix提供了
int pthread_attr_getschedpolicy(const pthread_attr_t *attr, int *policy);函数来获取所
使用的调度策略，它们是：

SCHED_FIFO, SCHED_RR 和 SCHED_OTHER。
我们可以使用

int sched_get_priority_max(int policy);
int sched_get_priority_min(int policy);
来获取线程线程可是设置的最大和最小的优先级值，如果调用成功就返回最大和最小的优先级值，否则返回－1。
从我现在运行的linux系统中，我使用下列程序获取了对应三种调度策略中的最大和最小优先级：
policy = SCHED_OTHER
Show current configuration of priority
max_priority = 0
min_priority = 0
Show SCHED_FIFO of priority
max_priority = 99
min_priority = 1
Show SCHED_RR of priority
max_priority = 99
min_priority = 1
Show priority of current thread
priority = 0
Set thread policy
Set SCHED_FIFO policy
policy = SCHED_FIFO
Set SCHED_RR policy
policy = SCHED_RR
Restore current policy
policy = SCHED_OTHER

我们可以看到
SCHED_OTHER
是不支持优先级使用的，而
SCHED_FIFO和SCHED_RR支持优先级的使用，他们分别为1和99，
数值越大
优先级越高。 从上面的结果我们可以看出，如果程序控制线程的优先级，一般是用
pthread_attr_getschedpolicy来获取系统使用的调度策略，如果是SCHED_OTHER的话，表明当前策略
不支持线程优先级的使用，否则可以。当然所设定的优先级范围必须在最大和最小值之间。我们可以通过
sched_get_priority_max
和
sched_get_priority_min来获取。
 

可能网友会问，是否我们可以通过

int pthread_attr_setschedpolicy(pthread_attr_t *attr, int policy);来设定自己所需的
调度策略呢？我觉得是完全可以的（有些系统需要定义
_POSIX_THREAD_PRIORITY_SCHEDULING），只要系统实现了对应的调用策略。

说了半天，我们还没有说，在系统允许使用线程优先级别的时候，如何设置优先级别呢？

int pthread_attr_setschedparam(pthread_attr_t *attr, 
    const struct sched_param *param);
int pthread_attr_getschedparam(const pthread_attr_t *attr, 
    struct sched_param *param);

上面两个函数分别用于设置线程的优先级，struct sched_param的定义如下

struct sched_param
{
    int __sched_priority; //所要设定的线程优先级
};

使用的测试程序：

#include <iostream>
#include <pthread.h>
#include <sched.h>
#include <assert.h>

using namespace std;

static int get_thread_policy( pthread_attr_t &attr )
{
        int policy;
        int rs = pthread_attr_getschedpolicy( &attr, &policy );
        assert( rs == 0 );
        switch ( policy )
        {
        case SCHED_FIFO:
                cout << "policy = SCHED_FIFO" << endl;
                break;

        case SCHED_RR:
                cout << "policy = SCHED_RR" << endl;
                break;

        case SCHED_OTHER:
                cout << "policy = SCHED_OTHER" << endl;
                break;

        default:
                cout << "policy = UNKNOWN" << endl;
                break;
        }

        return policy;
}

static void show_thread_priority( pthread_attr_t &attr, int policy )
{
        int priority = sched_get_priority_max( policy );
        assert( priority != -1 );
        cout << "max_priority = " << priority << endl;

        priority = sched_get_priority_min( policy );
        assert( priority != -1 );
        cout << "min_priority = " << priority << endl;
}

static int get_thread_priority( pthread_attr_t &attr )
{
        struct sched_param param;

        int rs = pthread_attr_getschedparam( &attr, &param );
        assert( rs == 0 );
        cout << "priority = " << param.__sched_priority << endl;

        return param.__sched_priority;
}

static void set_thread_policy( pthread_attr_t &attr,  int policy )
{
        int rs = pthread_attr_setschedpolicy( &attr, policy );
        assert( rs == 0 );
        get_thread_policy( attr );
}

int main( void )
{
        pthread_attr_t attr;
        struct sched_param sched;
        int rs;

        rs = pthread_attr_init( &attr );
        assert( rs == 0 );

        int policy = get_thread_policy( attr );

        cout << "Show current configuration of priority" << endl;
        show_thread_priority( attr, policy );

        cout << "Show SCHED_FIFO of priority" << endl;
        show_thread_priority( attr, SCHED_FIFO );

        cout << "Show SCHED_RR of priority" << endl;
        show_thread_priority( attr, SCHED_RR );

        cout << "Show priority of current thread" << endl;
        int priority = get_thread_priority( attr );

        cout << "Set thread policy" << endl;
        cout << "Set SCHED_FIFO policy" << endl;
        set_thread_policy( attr, SCHED_FIFO );
        cout << "Set SCHED_RR policy" << endl;
        set_thread_policy( attr, SCHED_RR );
        cout << "Restore current policy" << endl;
        set_thread_policy( attr, policy );


        rs = pthread_attr_destroy( &attr );
        assert( rs == 0 );

        return 0;
}