1

我想原子地修改结构的一些元素。我当前的实现使用互斥锁来保护关键代码,如下所示。

#include <stdio.h>
#include <stdlib.h>
#include <stdint.h>
#include <pthread.h>

pthread_mutex_t thread_mutex = PTHREAD_MUTEX_INITIALIZER;

#define ITER    100000

typedef struct global_status {
    int32_t context_delta;
    uint32_t global_access_count;
} global_status_t;

global_status_t g_status;

void *context0(void *ptr)
{
    unsigned int iter = ITER;
    while (iter--) {
        wait_event_from_device0();
        pthread_mutex_lock(&thread_mutex);
        g_status.context_delta++;
        g_status.global_access_count++;
        pthread_mutex_unlock(&thread_mutex);
    }

    return NULL;
}

void *context1(void *ptr)
{
    unsigned int iter = ITER;
    while (iter--) {
        wait_event_from_device1();
        pthread_mutex_lock(&thread_mutex);
        g_status.context_delta--;
        g_status.global_access_count++;
        pthread_mutex_unlock(&thread_mutex);
    }

    return NULL;
}

int main(int argc, char **argv)
{
    pthread_t tid0, tid1;
    int iret;

    if ((iret = pthread_create(&tid0, NULL, context0, NULL))) {
         fprintf(stderr, "context0 creation error!\n");
         return EXIT_FAILURE;
    }

    if ((iret = pthread_create(&tid1, NULL, context1, NULL))) {
         fprintf(stderr, "context1 creation error!\n");
         return EXIT_FAILURE;
    }

    pthread_join(tid0, NULL);
    pthread_join(tid1, NULL);

    printf("%d, %d\n", g_status.context_delta, g_status.global_access_count);
    return 0;
}

我打算将此代码移植到不支持 posix 的 RTOS 中,并且我想在不使用互斥锁或禁用/启用中断的情况下自动执行此操作。

我该怎么做这个操作?是否可以使用“原子比较和交换功能”(CAS)?

4

2 回答 2

0

似乎在您的示例中,您有两个线程为不同的设备提供服务。您也许可以使用每个设备结构完全取消锁定。全局将是所有每台设备统计信息的汇总。如果您确实需要锁,您可以使用 CAS、LL/SC 或任何受支持的底层原子构造。

于 2013-09-12T20:46:56.353 回答
0

我所做的是创建一个包含我想同时更改的所有字段的联合。像这样:

union {
  struct {
    int            m_field1;
    unsigned short m_field2 : 2,
                   m_field3 : 1;
    BYTE           m_field4; 
  }
  unsigned long long m_n64;
  TData(const TData& r) { m_n64 = r.m_n64; }
} TData;

您将这样的联合嵌入到较大的结构中,如下所示:

struct {
  ...
  volatile TData m_Data;
  ...
} TBiggerStruct;

然后我做这样的事情:

while (1) {
  TData Old = BiggerSharedStruct.m_Data, New = Old;
  New.field1++;
  New.field4--;
  if (CAS(&SharedData.m_n64, Old.m_n64, New.m_n64))
    break; // success
}

我将很多字段打包,同时希望将其更改为尽可能小的 16、32 或 64 位结构。我认为 intel 上的 128 位的东西不如 64 位的东西快,所以我避免使用它。我有一段时间没有对它进行基准测试,所以我可能错了。

于 2014-05-15T05:45:35.487 回答