『 Linux 』POSIX 信号量与基于环形队列的生产者消费者模型

news2024/9/21 4:28:33

文章目录

    • 信号量概念
    • POSIX 信号量
    • 基于环形队列的生产者消费者模型
    • 基于环形队列的生产者消费者模型编码实现
      • 基于环形队列的生产者消费者模型发送任务测试

信号量概念

请添加图片描述

信号量是一种用于多线程或多进程间同步的机制;

其定义是一个整形变量,本质上信号量可以看成是一个计数器,用来描述临界资源的资源数量;

通过信号量可以使多个执行流进行同步控制;

信号量主要通过P,V两个操作用来进行对信号量的控制:

  • P操作

    该操作用于减少信号量的值;

    当信号量不为0时一个执行流申请临界资源即为P操作;

    对应信号量将会-1;

    当信号量为0时其余执行流试图再次进行P操作时将会被阻塞,直至其中一个或多个执行流进行了V操作后信号量不为0时将会把该阻塞的执行流唤醒;

  • V操作

    该操作用于增加信号量的值;

    当一个执行流对对应的临界资源访问结束时将释放该信号量,即为V操作;

    对应信号量将会+1;

其中PV操作是被设计成具有原子性,确保执行流在进行P操作或是V操作时不可被其他执行流打断;

信号量的主要作用为:

  • 互斥访问

    保护临界资源,确保同一时间只有一个执行流访问临界资源;

  • 同步

    协调不同执行流的执行顺序;

  • 资源统计

    管理有限的临界资源数量;

信号量的类型有两种,分别为 “二元信号量” 和 “计数信号量” ;

  • 二元信号量

    二元信号量的值只能为0与1;

    当信号量的值为0时表示不可访问该临界资源,值为1时表示允许一个执行流访问临界资源;

  • 计数信号量

    技术信号量可以是任意非负整数;

    其中当信号量的值为0时表示不可访问该临界资源,值为非负整数且非零时表示允许该数值个数的执行流访问临界资源;

执行流对信号量的申请成功即P操作不代表该执行流访问了其临界资源,而是表示该执行流存持有对该临界资源访问的许可;

而获得访问该临界资源的许可是访问该临界资源的前提;

  • 信号量与临界资源状态

    当一个执行流成功进行了P操作后不再需要对临界资源状态进行判断;

    信号量是用来描述临界资源数量的,当信号量不为0时即表示该临界资源状态为就绪状态;

    这意味着申请信号量的本质就是间接判断了临界资源状态是否就绪的过程;

POSIX 信号量

请添加图片描述

POSIX 标准定义了一个信号量sem;

该信号量通常包含在<semaphore.h>头文件中,该信号量一般与 POSIX 互斥锁 pthread一同使用,故在包含<semaphore.h>头文件时需包含<pthread.h>头文件;

  • 信号量的定义

    POSIX信号量是一个类型为sem_t的结构体变量,其对应的结构可能类似于如下:

    typedef struct {
    int value;
    pthread_mutex_t lock;
    pthread_cond_t cond;
    // 可能还有其他字段
} sem_t;

    在使用该信号量前必须用该类型定义一个sem_t类型的变量或对象,如:

    sem_t sem;

    通过一系列接口控制信号量的操作,包括初始化,销毁,P操作,V操作等;

  • 初始化信号量

    通常使用sem_init()函数初始化信号量变量;

    NAME
       sem_init - initialize an unnamed semaphore

SYNOPSIS
       #include <semaphore.h>

       int sem_init(sem_t *sem, int pshared, unsigned int value);

       Link with -pthread.

RETURN VALUE
       sem_init() returns 0 on success; on error, -1 is returned, and errno is set to indicate the error.

    该函数用于初始化一个未命名的信号量,创建一个可以用于多线程同步的信号量对象;

    • sem_t *sem

      该参数为指向要初始化的信号量对象指针;

    • int pshared

      该参数指定信号量的共享性质;

      如果该参数为0则表示信号量在进程间的线程之间共享;

      如果该参数为非0则表示信号量在进程之间共享(非所有系统都支持);

    • unsigned int value

      该参数用于指定信号量的初始值;

    该函数调用成功返回0,调用失败返回-1并设置errno,通常可能的errno值为:

    • EINVAL

      表示value超过了信号量的最大允许值;

    • ENOSYS

      表示系统不支持进程共享的信号量(pshared为非0);

    • EPERM

      表示没有权限初始化信号量;

  • 销毁信号量

    通常调用sem_destroy()函数销毁信号量;

    NAME
       sem_destroy - destroy an unnamed semaphore

SYNOPSIS
       #include <semaphore.h>

       int sem_destroy(sem_t *sem);

       Link with -pthread.

RETURN VALUE
       sem_destroy() returns 0 on success; on error, -1 is returned, and errno is set to indicate the error.

    该函数用于清理和释放无名信号量的资源,通常在程序结束或是不再需要改信号量时调用;

    其中参数sem_t *sem表示传入一个指向要销毁的信号量的指针;

    该函数调用成功时返回0,调用失败返回-1并设置errno来指示错误信息,该函数调用失败可能出现的errno为:

    • EINVAL

      表示所传入信号量不是有效的信号量;

    • EBUSY

      表示有线程正在等待这个信号量;

    该函数只能用于销毁通过sem_init()初始化的无名信号量,无法用于销毁命名信号量(sem_open()创建的信号量);

    同时若是使用该函数销毁一个正在使用的信号量可能会导致未定义行为;

    销毁后的信号量不能再被使用,除非重新调用sem_init()初始化;

  • P操作

    通常使用sem_wait()函数进行P操作;

    NAME
       sem_wait

SYNOPSIS
       #include <semaphore.h>

       int sem_wait(sem_t *sem);

       Link with -pthread.

   Feature Test Macro Requirements for glibc (see feature_test_macros(7)):

       sem_timedwait(): _POSIX_C_SOURCE >= 200112L || _XOPEN_SOURCE >= 600

RETURN VALUE
       All  of  these functions return 0 on success; on error, the value of the semaphore is left unchanged, -1
       is returned, and errno is set to indicate the error.

    该函数用于等待信号量,即P操作;

    如果信号量的值大于0时则将其减1并立即返回,如果信号量的值为0时则阻塞线程,直至信号量大于0;

    其中参数sem_t *sem表示传入一个指向要等待的信号量的指针;

    函数调用成功时返回0,调用失败时返回-1并设置errno,其中常见的错误为:

    • EINTR

      表示等待被信号处理程序中断;

    • EINVAL

      表示传入的信号量sem不是有效的信号量;

    同样的P操作相关的函数有:

           int sem_trywait(sem_t *sem);

       int sem_timedwait(sem_t *sem, const struct timespec *abs_timeout);

  • V操作

    通常使用sem_post()函数进行V操作;

    NAME
       sem_post - unlock a semaphore

SYNOPSIS
       #include <semaphore.h>

       int sem_post(sem_t *sem);

       Link with -pthread.

DESCRIPTION
       sem_post()  increments (unlocks) the semaphore pointed to by sem.  If the semaphore's value consequently
       becomes greater than zero, then another process or thread blocked in a sem_wait(3) call will be woken up
       and proceed to lock the semaphore.

RETURN VALUE
       sem_post() returns 0 on success; on error, the value of the semaphore is left unchanged, -1 is returned,
       and errno is set to indicate the error.

    该函数用于释放(解锁)一个信号量,即V操作;

    其中参数sem_t *sem表示传入一个指向要释放的信号量的指针;

    该函数调用成功时返回0,调用失败时返回-1,同时调用失败时其信号量的值保持不变并设置errno来指示错误原因,该函数可能的错误为:

    • EINVAL

      表示sem不是有效的信号量;

    • EOVERFLOW

      表示信号量的最大值将被超过;

    与P操作相同,该操作也是一个原子性操作;

    如果有多个线程在等待同一个信号量时将只会唤醒其中一个线程;

    若是过渡调用该函数可能导致信号量值溢出;

基于环形队列的生产者消费者模型

请添加图片描述

基于环形队列的生产者消费者模型本质与生产者消费者模型无异;

其包含了生产者消费者的几个要素:

  • 三种关系

    • 消费者与消费者的互斥关系
    • 生产者与生产者的互斥关系
    • 生产者与消费者的同步互斥关系

  • 两个角色

    • 生产者

      负责生产数据并放入环形队列中,当队列满时生产者需要等待;

    • 消费者

      负责从环形队列中取出数据并对数据加工处理,当队列为空时,消费者需等待;

  • 一个交易场所

    一块特定结构的共享空间,在该设计中环形队列为消费者与生产者的交易场所;

    其中该环形队列是一个固定大小的缓冲区,通常用数组实现,其环形结构用当前生产者或消费者的位置对该固定大小的缓冲区进行取模操作;

    头尾指针循环使用形成一个逻辑上的环,该空间用于存储生产者锁生产的数据供消费者消费;

以单生产者单消费者为例,其生产者与消费者必须在环形队列中遵守三条规则:

  • 生产者与消费者处于同一位置时无法同时访问

    当生产者与消费者处于同一位置时表示环形队列可能处于空状态或是满状态两种状态;

    • 队列为空

      当队列为空时表示队列中不存在数据,此时消费者必须等待生产者生产数据;

    • 队列为满

      当队列为满时即生产者无法生产数据,必须阻塞等待至消费者消费一个或多个数据;

  • 消费者无法超过生产者一圈

    消费者超过生产者,在超过之前必定与生产者处于同一位置,由于消费者的位置>生产者意味着当前同一位置队列为空;

    消费者若是超过生产者则表示在队列的空位置处消费数据,将会发生错误;

  • 生产者无法超过消费者一圈

    生产者在超过消费者之前必定与消费者处于同一位置,此时意味着当前队列状态为满;

    若是生产者在此时超过消费者则意味着在已有数据的位置再次放入数据进行覆盖,将会发生问题;

对于生产者而言其关注的资源为当前队列中可存入数据的空间;

对于消费者而言其关注的资源为当前队列中存在多少数据;

因此在使用信号量实现基于环形队列的生产者消费者模型时需要存在两个信号量来分别控制生产者和消费者所关注的资源;

即生产者对应的信号量用来描述当前队列中可存入数据的空间,消费者对应的信号量用来描述当前队列中存在的数据量;

  • 多生产者多消费者下的环形队列

    在该模型中生产者和生产者必须产生互斥,消费者与消费者也必须产生互斥,所以无论是单生产者单消费者还是多生产者多消费者的情况下,同一时间能够在唤醒队列进行生产消费的只有一个生产者与消费者;

基于环形队列的生产者消费者模型编码实现

请添加图片描述

该模型与基于阻塞队列的生产者消费者模型类似,存在三种关系,两种角色和一个交易场所;

唯一不同的是基于环形队列的生产者消费者模型利用信号量使得生产者与消费者能够互斥与同步;

/* RingQueue.hpp */

#ifndef RING_QUEUE_HPP
#define RING_QUEUE_HPP
#include <pthread.h>
#include <semaphore.h>
#include <vector>

// 定义一个模板类 RingQueue，可以存储任意类型 T 的数据
template <class T>
class RingQueue {
  const static int defaultnum = 10;  // 默认队列大小

 private:
  // 封装信号量的 P 操作（等待）
  void P(sem_t &sem) { sem_wait(&sem); }
  // 封装信号量的 V 操作（释放）
  void V(sem_t &sem) { sem_post(&sem); }
  // 封装互斥锁的加锁操作
  void Lock(pthread_mutex_t &mutex) { pthread_mutex_lock(&mutex); }
  // 封装互斥锁的解锁操作
  void Unlock(pthread_mutex_t &mutex) { pthread_mutex_unlock(&mutex); }

 public:
  // 构造函数，初始化队列和同步原语
  RingQueue(int maxcap = defaultnum)
      : queue_(maxcap), maxcap_(maxcap), cstep_(0), pstep_(0) {
    sem_init(&sem_data_, 0, 0);  // 初始化数据信号量，初始值为0
    sem_init(&sem_space_, 0, maxcap_);  // 初始化空间信号量，初始值为最大容量
    pthread_mutex_init(&c_lock_, nullptr);  // 初始化消费者互斥锁
    pthread_mutex_init(&p_lock_, nullptr);  // 初始化生产者互斥锁
  }

  // 生产者方法：向队列中添加数据
  void Push(const T &data) {
    P(sem_space_);  // 等待有可用空间
    Lock(p_lock_);  // 加锁，确保生产者之间互斥

    queue_[pstep_] = data;  // 将数据放入队列
    pstep_ = (pstep_ + 1) % maxcap_;  // 更新生产者索引，保持环形

    V(sem_data_);  // 增加可用数据的信号量
    Unlock(p_lock_);  // 解锁
  }

  // 消费者方法：从队列中取出数据
  void Pop(T *out) {
    P(sem_data_);  // 等待有可用数据
    Lock(c_lock_);  // 加锁，确保消费者之间互斥

    *out = queue_[cstep_];  // 取出数据
    cstep_ = (cstep_ + 1) % maxcap_;  // 更新消费者索引，保持环形

    Unlock(c_lock_);  // 解锁
    V(sem_space_);  // 增加可用空间的信号量
  }

  // 析构函数，清理资源
  ~RingQueue() {
    sem_destroy(&sem_data_);  // 销毁数据信号量
    sem_destroy(&sem_space_);  // 销毁空间信号量
    pthread_mutex_destroy(&c_lock_);  // 销毁消费者互斥锁
    pthread_mutex_destroy(&p_lock_);  // 销毁生产者互斥锁
  }

 private:
  std::vector<T> queue_;  // 存储数据的环形队列
  int maxcap_;  // 队列最大容量
  int cstep_;  // 消费者当前位置
  int pstep_;  // 生产者当前位置
  sem_t sem_data_;   // 可用数据的信号量
  sem_t sem_space_;  // 可用空间的信号量
  pthread_mutex_t c_lock_;  // 消费者互斥锁
  pthread_mutex_t p_lock_;  // 生产者互斥锁
};

#endif

这是一个环形队列的实现,使用模板设计,可以存储任意类型数据;

使用了信号量和互斥锁来实现线程同步与互斥:

  • sem_t sem_data_

    该信号量表示队列中可用数据的数量,为消费者所关注的资源;

  • sem_t sem_space_

    该信号量表示队列中可用空间的数量,为生产者所关注的资源;

  • pthread_mutex_t c_lock_

    用于保持多消费者情况下消费者之间的互斥关系,确保只有一个消费者线程能够访问其对应的临界资源;

  • pthread_mutex_t p_lock_

    用于保持多生产者情况下生产者之间的互斥关系,确保只有一个生产者线程能够访问其对应的临界资源;

并且将信号量的P操作,V操作与互斥锁的Lock操作,Unlock操作进行封装,以便捷使用;

其中Push()操作为生产操作,当存在可用空间时生产者对空间信号量进行P操作生产数据,当数据生产完毕后对资源信号量进行V操作;

Pop()操作为消费操作,当存在可消费资源时消费者对资源信号量进行P操作消费数据,当数据消费完毕后对空间信号量进行V操作;

其中Push生产者方法逻辑如下:

  • 等待可用空间(对sem_space_进行P操作)
  • 加锁Lock(p_lock_)保证生产者之间保持互斥
  • 将数据放入队列并更新生产者索引p_step_
  • 增加可用数据信号量(对sem_data_进行V操作)

Pop消费者方法逻辑如下:

  • 等待可用资源(对sem_data_进行P操作)
  • 加锁Lock(c_lock_)保证消费者之间保持互斥
  • 从队列中取出数据并更新消费者索引c_step_
  • 增加可用空间信号量(对sem_space_进行V操作)

其环形逻辑采用cstep_和pstep_来跟踪消费者和生产者的位置,并通过取模运算实现逻辑环形;

构造函数初始化所有成员和同步互斥语句(信号量,互斥锁);

析构函数负责清理所有资源(信号量,互斥锁);

以多生产者多消费者为例进行测试(内置类型数据):

/* main.cc */

#include <pthread.h>
#include <unistd.h>
#include <cstdio>
#include <cstdlib>
#include <ctime>
#include "RingQueue.hpp"

using namespace std;

// 生产者线程函数
void *Productor(void *args) {
  RingQueue<int> *rq = static_cast<RingQueue<int> *>(args);
  while (true) {
    int data = rand() % 10;  // 生成0-9的随机数
    usleep(10);  // 短暂休眠，模拟生产过程
    rq->Push(data);  // 将数据放入环形队列
    printf("The thread-%3lu production a data :%2d\n", pthread_self() % 1000, data);
  }
  return nullptr;
}

// 消费者线程函数
void *Consumer(void *args) {
  RingQueue<int> *rq = static_cast<RingQueue<int> *>(args);
  while (true) {
    int data = 0;
    rq->Pop(&data);  // 从环形队列中取出数据
    printf("The thread-%3lu get a data :%2d\n", pthread_self() % 1000, data);
    usleep(800000);  // 休眠0.8秒，模拟消费过程
  }
  return nullptr;
}

int main() {
  srand(time(nullptr));  // 初始化随机数种子
  RingQueue<int> *rq = new RingQueue<int>();  // 创建环形队列

  pthread_t p_tids[3], c_tids[3];  // 定义3个生产者和3个消费者线程

  // 创建3个生产者线程
  for (size_t i = 0; i < 3; ++i) {
    pthread_create(&p_tids[i], nullptr, Productor, rq);
  }

  // 创建3个消费者线程
  for (size_t i = 0; i < 3; ++i) {
    pthread_create(&c_tids[i], nullptr, Consumer, rq);
  }

  // 等待所有生产者线程结束
  for (size_t i = 0; i < 3; ++i) {
    pthread_join(p_tids[i], nullptr);
  }

  // 等待所有消费者线程结束
  for (size_t i = 0; i < 3; ++i) {
    pthread_join(c_tids[i], nullptr);
  }

  delete rq;  // 释放环形队列内存
  return 0;
}

该段代码进行了一个简单的测试,生产者线程通过Productor()函数循环向队列中放置0-9的数据并打印对应信息;

消费者线程通过Consumer()函数每隔0.8秒循环向队列中取出数据并打印对应信息;

主函数创建了三个生产者线程与三个消费者线程进行这些工作;

代码运行结果为:

$ ./ringqueue 
The thread- 96 production a data : 2
The thread-688 get a data : 9
The thread-392 production a data : 9
The thread-800 production a data : 4
The thread-984 get a data : 4
The thread-280 get a data : 2
The thread-800 production a data : 4
The thread- 96 production a data : 4
The thread-392 production a data : 6
...
...

与预期相同;

基于环形队列的生产者消费者模型发送任务测试

请添加图片描述

生产者消费者模型被设计成类模板,表示其可传输任何类型的数据,包括自定义类型;

假设存在一个任务为Task:

/* Task.hpp */

#ifndef TASK_HPP
#define TASK_HPP
#include <iostream>

// 定义错误代码枚举
enum { DIV_ERR = 1, MOD_ERR, NONE };

class Task {
 public:
  Task() {}  // 默认构造
             // 便于环形生产者消费者模型能够进行默认构造初始化并进行默认拷贝构造

  // 构造函数：初始化所有成员变量
  Task(int num1, int num2, char oper)
      : num1_(num1), num2_(num2), exit_code_(0), result_(0), oper_(oper) {}

  // 析构函数（当前为空）
  ~Task() {}

  // 执行任务的主要函数
  void run() {
    switch (oper_) {
      case '+':
        result_ = num1_ + num2_;
        break;
      case '-':
        result_ = num1_ - num2_;
        break;
      case '*':
        result_ = num1_ * num2_;
        break;
      case '/': {
        if (num2_ == 0) {
          exit_code_ = DIV_ERR;  // 设置除零错误
          result_ = -1;          // 除零时结果设为-1
        } else
          result_ = num1_ / num2_;
        break;
      }
      case '%': {
        if (num2_ == 0) {
          exit_code_ = MOD_ERR;  // 设置模零错误
          result_ = -1;          // 模零时结果设为-1
        } else
          result_ = num1_ % num2_;
        break;
      }
      default:
        exit_code_ = NONE;  // 未知操作符
        break;
    }
  }

  // 重载()运算符，使对象可以像函数一样被调用
  void operator()() { run(); }

  // 获取计算结果
  int getresult() { return result_; }

  // 获取退出代码
  int getexitcode() { return exit_code_; }

  // 获取第一个操作数
  int getnum1() { return num1_; }

  // 获取第二个操作数
  int getnum2() { return num2_; }

  // 获取操作符
  char getoper() { return oper_; }

 private:
  int num1_;       // 第一个操作数
  int num2_;       // 第二个操作数
  int exit_code_;  // 退出代码，用于表示操作是否成功
  int result_;     // 计算结果
  char oper_;      // 操作符
};

#endif

其中定义了几个getter函数获取对应的私有属性;

使用run()函数进行核心操作,实现了基本的+-*/%,并将()运算符重载为该函数;

其中对应的测试代码为如下(单生产者单消费者情况):

/* main.cc */

using namespace std;

// 定义可能的运算符
string opers = "+-*/%";

// 生产者线程函数
void *Productor(void *args) {
  RingQueue<Task> *rq = static_cast<RingQueue<Task> *>(args);
  while (true) {
    int data1 = rand() % 10;
    usleep(10);
    int data2 = rand() % 10;
    usleep(10);
    char op = opers[rand() % opers.size()];

    Task task(data1, data2, op);
    rq->Push(task);
    printf("The thread-%3lu sent a task : %d %c %d = ?\n",
           pthread_self() % 1000, data1, op, data2);
    sleep(1);
  }
  return nullptr;
}

// 消费者线程函数
void *Consumer(void *args) {
  RingQueue<Task> *rq = static_cast<RingQueue<Task> *>(args);
  while (true) {
    Task task;
    rq->Pop(&task);
    task();
    printf("The thread-%3lu get a task : %d %c %d = %2d , exitcode: %d\n",
           pthread_self() % 1000, task.getnum1(), task.getoper(),
           task.getnum2(), task.getresult(), task.getexitcode());
    sleep(1);
  }
  return nullptr;
}

int main() {
  srand(time(nullptr));                         // 初始化随机数种子
  RingQueue<Task> *rq = new RingQueue<Task>();  // 创建任务队列

  pthread_t p_tids[1], c_tids[1];  // 定义1个生产者和1个消费者线程

  // 创建1个生产者线程
  pthread_create(&p_tids[0], nullptr, Productor, rq);

  // 创建1个消费者线程
  pthread_create(&c_tids[0], nullptr, Consumer, rq);

  // 等待生产者线程结束（实际上不会结束）
  pthread_join(p_tids[0], nullptr);

  // 等待消费者线程结束（实际上不会结束）
  pthread_join(c_tids[0], nullptr);

  delete rq;  // 释放队列内存（实际上不会执行到这里）
  return 0;
}

其中Productor()函数随机生成两个0-9之间的数字和一个运算符将其构造出一个Task对象并推入队列中进行生产工作并打印对应生成的任务信息;

Consumer()函数以默认构造创建一个Task对象并将该对象取地址调用Pop()函数取出,并直接调用task()进行执行任务而后打印任务结果和退出码,每消费一个任务后sleep(1);

main()函数创建一个RingQueue<Task>对象同时创建一个生产者和一个消费者并等待这两个线程结束;

运行结果为:

$ ./ringqueue 
The thread-648 sent a task : 9 * 0 = ?
The thread-944 get a task : 9 * 0 =  0 , exitcode: 0
The thread-648 sent a task : 8 + 3 = ?
The thread-944 get a task : 8 + 3 = 11 , exitcode: 0
The thread-648 sent a task : 5 * 1 = ?
The thread-944 get a task : 5 * 1 =  5 , exitcode: 0
The thread-648 sent a task : 9 * 9 = ?
The thread-944 get a task : 9 * 9 = 81 , exitcode: 0
The thread-648 sent a task : 5 - 8 = ?
The thread-944 get a task : 5 - 8 = -3 , exitcode: 0
The thread-648 sent a task : 3 / 2 = ?
The thread-944 get a task : 3 / 2 =  1 , exitcode: 0
The thread-648 sent a task : 4 / 1 = ?
The thread-944 get a task : 4 / 1 =  4 , exitcode: 0
...
...

印任务结果和退出码,每消费一个任务后sleep(1);

main()函数创建一个RingQueue<Task>对象同时创建一个生产者和一个消费者并等待这两个线程结束;

运行结果为:

$ ./ringqueue 
The thread-648 sent a task : 9 * 0 = ?
The thread-944 get a task : 9 * 0 =  0 , exitcode: 0
The thread-648 sent a task : 8 + 3 = ?
The thread-944 get a task : 8 + 3 = 11 , exitcode: 0
The thread-648 sent a task : 5 * 1 = ?
The thread-944 get a task : 5 * 1 =  5 , exitcode: 0
The thread-648 sent a task : 9 * 9 = ?
The thread-944 get a task : 9 * 9 = 81 , exitcode: 0
The thread-648 sent a task : 5 - 8 = ?
The thread-944 get a task : 5 - 8 = -3 , exitcode: 0
The thread-648 sent a task : 3 / 2 = ?
The thread-944 get a task : 3 / 2 =  1 , exitcode: 0
The thread-648 sent a task : 4 / 1 = ?
The thread-944 get a task : 4 / 1 =  4 , exitcode: 0
...
...

结果与预期相符;

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1973399.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

记录一次服务器被（crontab）木马入侵事件

记录一次服务器被（crontab）木马入侵事件

背景&#xff1a;发现平时正常登录的服务器突然进不去&#xff0c;也没明显的错误&#xff0c;重启也登录不了&#xff01; 可能的原因&#xff0c;内存/CPU满了 重启通过用户模式进入&#xff0c;查看进程发现有个定时任务一直在自动创建并执行&#xff08;进程ID一直在变化&a…
阅读更多...
机械学习—零基础学习日志（高数19——函数极限理解深化）

机械学习—零基础学习日志（高数19——函数极限理解深化）

零基础为了学人工智能&#xff0c;真的开始复习高数 本次学习笔记&#xff0c;主要讲解函数极限的计算问题。 极限四则运算规则 这里有几个需要注意的地方。函数极限的四则运算&#xff0c;需要知道极限存在才能大胆放心的使用。而且使用超实数的概念会更好帮助我们理解&…
阅读更多...
Python 操作PPT幻灯片- 添加、删除、或隐藏幻灯片

Python 操作PPT幻灯片- 添加、删除、或隐藏幻灯片

PowerPoint文档是商务、教育、创意等各领域常见的用于展示、教育和传达信息的格式。在制作PPT演示文稿时&#xff0c;灵活地操作幻灯片是提高演示效果、优化内容组织的关键步骤。下面将介绍如何使用国产Spire.Presentation for Python库实现添加、删除或隐藏PPT幻灯片。 目录 …
阅读更多...
浅谈Java线程池的概念

浅谈Java线程池的概念

目录 说明 1.线程池特点 2.线程池的简单示例 2.1 定义一个线程池类&#xff0c;通过创建一个全局的阻塞队列接收任务&#xff0c;线程池类构造方法拿阻塞队列的线程&#xff0c;完成线程的执行。 3. main方法中调用该类&#xff0c;实现线程池的调用 4.效果如下 说明 线程…
阅读更多...
MySql Linux 安装

MySql Linux 安装

下载 下载后的文件为&#xff1a;mysql-8.4.2-linux-glibc2.28-x86_64.tar.xz 创建用户和用户组 $> groupadd mysql $> useradd -r -g mysql -s /bin/false mysql由于用户仅用于所有权目的&#xff0c;而不是登录目的&#xff0c;因此useradd命令使用 -r和-s /bin/false…
阅读更多...
C++笔记之编译过程和面向对象

C++笔记之编译过程和面向对象

回顾&#xff1a; “abcd”//数据类型 字符串常量 const char *p"abc"; new STU const char *//8 指针的内存空间 int float 指针的内存空间 p 指针指向的内存空间 "abc" 取决于字符串长度 指针变量的内容一级指针 指针变量的地址二级指针 …
阅读更多...
深度学习------权重衰退

深度学习------权重衰退

目录 使用均方范数作为硬性限制使用均方范数作为柔性限制演示最优解的影响参数更新法则总结高纬线性回归多项式的权重衰退从零开始实现初始化模型参数定义L2范数惩罚定义训练代码实现忽略正则化直接训练使用权重衰减从零开始代码实现 多项式的权重衰退的简洁实现简洁函数代码简…
阅读更多...
案例分享｜Alluxio在自动驾驶数据闭环中的应用

案例分享｜Alluxio在自动驾驶数据闭环中的应用

分享嘉宾&#xff1a; 孙涛 - 中汽创智智驾工具链数据平台开发专家 关于中汽创智&#xff1a; 中汽创智科技有限公司&#xff08;以下简称“中汽创智”&#xff09;由中国一汽、东风公司、南方工业集团、长安汽车和南京江宁经开科技共同出资设立。聚焦智能底盘、新能动力、智…
阅读更多...
学习硬件测试04：触摸按键+PWM 驱动蜂鸣器+数码管（P62~P67、P71、P72）

学习硬件测试04：触摸按键+PWM 驱动蜂鸣器+数码管（P62~P67、P71、P72）

一、触摸按键 1.1理论讲解 1.1.1实验现象 触摸按键 1 单击与长按&#xff0c;控制 LED1&#xff1b;触摸按键 2 单击与长按&#xff0c;控制 LED2;触摸按键 3 单击与长按&#xff0c;控制 LED3;触摸按键 4 单击与长按&#xff0c;控制继电器; 1.1.2硬件电路 是原理图上触摸…
阅读更多...
vue3+element-plus实现table表格整列的拖拽

vue3+element-plus实现table表格整列的拖拽

参考文章&#xff1a;https://blog.csdn.net/candy0521/article/details/136470284 一、为防止原文章不见了将参考文章代码拷过来了&#xff08;不好意思&#xff09;&#xff1a;这是参考文章的代码 可直接复制粘贴运行 <template><div class"draggable-table&…
阅读更多...
uniapp 多渠道打包实现方案

uniapp 多渠道打包实现方案

首先一个基础分包方案&#xff1a; 包不用区分渠道&#xff0c;只是通过文件名进行区分&#xff0c;公共代码逻辑可以通过mixins进行混入。 这样分包后就需要在打包时只针对编译的渠道包文件进行替换打包&#xff0c;其他渠道包的文件不打包进去&#xff0c;通过工具类实现…
阅读更多...
VS Code 搭建 Python 环境 Conda管理

VS Code 搭建 Python 环境 Conda管理

官网教程
阅读更多...
商业策划案怎么写？附商场230个策划案例

商业策划案怎么写？附商场230个策划案例

商业策划案的撰写是一个系统性工程&#xff0c;旨在详细阐述项目的背景、目标、实施策略、财务预测及风险评估等内容&#xff0c;以吸引投资者或合作伙伴的关注。 以下是一个详细的撰写步骤和要点&#xff0c;码字不易&#xff0c;如果回答对你有所帮助&#xff0c;请不吝给一…
阅读更多...
GraphRAG如何使用ollama提供的llm model 和Embedding model服务构建本地知识库

GraphRAG如何使用ollama提供的llm model 和Embedding model服务构建本地知识库

使用GraphRAG踩坑无数 在GraphRAG的使用过程中将需要踩的坑都踩了一遍&#xff08;不得不吐槽下&#xff0c;官方代码有很多遗留问题&#xff0c;他们自己也承认工作重心在算法的优化而不是各种模型和框架的兼容性适配性上&#xff09;&#xff0c;经过了大量的查阅各种资料以…
阅读更多...
【目标和】python刷题记录

【目标和】python刷题记录

R3-dp篇. 目录 思路&#xff1a; 增加记忆化搜索&#xff1a; 优化空间复杂度&#xff1a; 思路&#xff1a; class Solution:def findTargetSumWays(self, nums: List[int], target: int) -> int:#设正数之和为p,总元素之和为s&#xff0c;带符号总元素之和为t&…
阅读更多...
AWS开发人工智能:如何基于云进行开发人工智能AI

AWS开发人工智能:如何基于云进行开发人工智能AI

随着人工智能技术的飞速发展&#xff0c;企业对高效、易用的AI服务需求日益增长。Amazon Bedrock是AWS推出的一项创新服务&#xff0c;旨在为企业提供一个简单、安全的平台&#xff0c;以访问和集成先进的基础模型。本文中九河云将详细介绍Amazon Bedrock的功能特点以及其收费方…
阅读更多...
安卓常用控件（上）

安卓常用控件（上）

文章目录 TextViewButtonEditText TextView textview主要用于在界面上显示一段文本信息。 属性名描述id给当前控件定义一个唯一的标识符。layout_width给控件指定一个宽度。match_parent&#xff1a;控件大小与父布局一样&#xff1b;wrap_content&#xff1a;控件大小刚好够包…
阅读更多...
WinUI vs WPF vs WinForms: 三大Windows UI框架对比

WinUI vs WPF vs WinForms: 三大Windows UI框架对比

1.前言 在Windows平台上开发桌面应用程序时&#xff0c;WinUI、WPF和WinForms是三种主要的用户界面框架。每种框架都有其独特的特点和适用场景。本文将通过示例代码&#xff0c;详细介绍这些框架的优缺点及其适用场景&#xff0c;帮助dotnet桌面开发者更好地选择适合自己项目的…
阅读更多...
【Spring】SSM框架整合Spring和SpringMVC

【Spring】SSM框架整合Spring和SpringMVC

目录 1.项目结构 2.项目的pom.xml文件 3.spring.xml和springMVC配置文件 4.database.properties和mybatis.xml配置文件 5. 代码编写 6.测试整合结果 1.项目结构 首先创建一个名为ssm_pro的Mavew项目&#xff0c;然后再在主目录和资源目录下&#xff0c;创建如下所示的结…
阅读更多...
5.2-软件工程基础知识-软件过程模型

5.2-软件工程基础知识-软件过程模型

软件过程模型 瀑布模型瀑布模型变种-V模型演化模型-原型模型增量模型演化模型-螺旋模型喷泉模型基于构件的开发模型形式化方法模型统一过程模型敏捷方法极限编程其他方法 软件过程模型概述练习题 瀑布模型 瀑布模型(SDLC):瀑布模型是一个经典的生命周期模型&#xff0c;一般将软…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023