TinySTM源代码分析.pptVIP

tinySTM使用： 初始化STM（stm_init） 初始化线程 barrier_init(barrier, nb_threads + 1); pthread_attr_init(attr); pthread_attr_setdetachstate(attr, PTHREAD_CREATE_JOINABLE); 创建多个线程 pthread_create(threads[i], attr, test, (void *)(data[i])) 线程运行函数test Initialize a transational thread(stm_init_thread) 执行事务操作并提交(stm_load,stm_store,stm_commit) Clean up a transactional thread 等待线程完成 退出事务（stm_exit） TinySTM初始化 TinySTM初始化（stm_init忽略掉优先级竞争管理模式CM_PRIORITY，直接更新WRITE_BACK_ELT，未作特殊说明都按此处理） 定义sigaction结构act（信号处理结构） 将锁队列置零，CLOCK置零 memset((void *)locks, 0, LOCK_ARRAY_SIZE * sizeof(stm_word_t)); 初始化sigaction act.sa_handler = signal_catcher; act.sa_flags = 0; sigemptyset(act.sa_mask); TinySTM线程初始化 TinySTM线程初始化（stm_init_thread） 定义stm_tx_t（transaction descripor）结构，并赋初值(结构见下页) typedef struct stm_tx { /* Transaction descriptor */ stm_tx_attr_t *attr; /* Transaction attributes (user-specified) */ stm_word_t status; /* Transaction status (not read by other threads) */ stm_word_t start; /* Start timestamp */ stm_word_t end; /* End timestamp (validity range) */ r_set_t r_set; /* Read set */ w_set_t w_set; /* Write set */ sigjmp_buf env; /* Environment for setjmp/longjmp */ sigjmp_buf *jmp; /* Pointer to environment (NULL when not using setjmp/longjmp) */ int nesting; /* Nesting level */ int ro; /* Is this execution read-only? */ int can_extend; /* Can this transaction be extended? */ void *data[MAX_SPECIFIC]; /* Transaction-specific data (fixed-size array for better speed) */ #ifdef CONFLICT_TRACKING pthread_t thread_id; /* Thread identifier (immutable) */ #endif /* CONFLICT_TRACKING */ #if CM == CM_DELAY || CM == CM_PRIORITY volatile stm_word_t *c_lock; /* Pointer to contented