我在C中编写并发事务库,发现了以下问题.让我们考虑一个示例事务成员伪代码,其中"transaction"表示与事务主机的通信通道:
transaction = trans_join();
do_some_ops();
/* receive the data from the master */
trans_rcv(transaction, data);
do_some_ops();
trans_send(transaction, answer);
/* wait for the possibility for voting */
trans_ready(transaction);
/* vote for commiting and wait for the voting results. */
if(trans_commit(answer))
{
printf("Final commiting the changes.\n");
}
else
{
printf("Rolling back the changes.\n");
}
Run Code Online (Sandbox Code Playgroud)
在并发交易中,我们只有在被要求主人投票时才能投票.但是,主服务器可以随时调用trans_abort(member),强制指定的成员取消该事务.成员在执行的任何阶段都可以接收ABORT消息,在这种情况下,它不应该等到执行到达trans_ready()呼叫.例如,如果trans_rcv()在后面的代码中有一个调用,则该进程将在等待来自主服务器的数据时挂起,该数据将永远不会被发送.
现在,重点.我已经在代码注册中止功能回滚的变化,但我也想有一个额外的机制,让跳过其余操作的其余部分,并立即跳转到投票代码.我有一个想法,在这里使用goto来模拟异常:
if(!trans_rcv()) /* fail, we received the abort message */
{
goto abort_code;
}
...
abort_code:
trans_ready(transaction);
/* etc. */
Run Code Online (Sandbox Code Playgroud)
但是,为每次调用编写 …