Chinaunix首页 | 论坛 | 博客
  • 博客访问: 92399010
  • 博文数量: 19283
  • 博客积分: 9968
  • 博客等级: 上将
  • 技术积分: 196062
  • 用 户 组: 普通用户
  • 注册时间: 2007-02-07 14:28
文章分类

全部博文(19283)

文章存档

2011年(1)

2009年(125)

2008年(19094)

2007年(63)

分类: C/C++

2008-05-18 20:42:06

 来源:


  逻辑流程VS线程

  逻辑流程看起来像是线程,但它实际上运行在创建它的线程空间之内。尽管两者都有独立的进程堆栈,但逻辑流程的开销要小一些,且不用处理流程间的同步问题。

  逻辑流程也能用于异常处理。例如,可添加类似如下的代码:

START_FLOW {
FLOW_WAIT(read_err=);

}

START_FLOW {
FLOW_WAIT(current_tick & last_receive_tick >= RECEIVE_TIMEOUT);

}

  示例对比

  下面还有一个例子演示了流程的可伸缩性及威力,比如说要解析以下格式的URL:

[scheme://[user:pass@]host[:port]]/]uri[?param[#ankor]]

  如果只想遍历URL字符串一次,可能会编写如下代码:

void URL::ParseString(const string &url)
{
string s;
s.reserve(url.length());
if (Original.empty())
Original = url;
OriginalLength = url.length();
const char *p = url.c_str();

//解析scheme [http:]

while (*p && (*p != '/') && (*p != ':') &&
(*p != ';') && (*p != '?') &&
(*p != '#')) s += *p++;

if (*p == ':')
{
Scheme = s;
p++;
s.resize(0);
while (*p && (*p != '/') && (*p != ';') &&
(*p != '?') && (*p != '#')) s += *p++;
}

// 解析 //[user[:pass]@]host[:port]/
// 解析端口)

if (*p && (*p == '/') && (*(p+1) == '/'))
{
p+=2;
s.resize(0);
while (*p && (*p != '/') && (*p != ':') &&
(*p != '@')) s += *p++;
Host = s;
if (*p == ':')
{
s.resize(0);
while (*p && (*p != '/') && (*p != '@')) s += *p++;
if (*p != '@') Port = IP_PORT(atol(&s[0]));
}

if (*p == '@')
{
p++;
if (Host.length() == 0)
{
User = s;
}
else
{
User = Host;
Password = s;
Host.resize(0);
}
s.resize(0);
while (*p && (*p != '/') && (*p != ':')) s += *p++;
Host = s;
if (*p == ':')
{
p++;
s.resize(0);
while (*p && *p != '/') s += *p++;
Port = IP_PORT(atol(&s[0]));
}
}

//重建NetLoc字符串

if (User.length())
{
NetLoc = User;
if (Password.length())
{
NetLoc += ":";
NetLoc += Password;
}
NetLoc += '@';
}

NetLoc += Host;
if (Port != 80)
{
char portstring[15];
NetLoc += ':';
sprintf(portstring, "%d", Port);
NetLoc += portstring;
}

s.resize(0);
}

//解析路径[/a[/b[..]]/]与文件
//如果遇到'/'且s不为空,这是一个相对路径。

if (s.length() && (*p == '/'))
{
p++;
RelativePath = true;
Path.push_back(s);
s.resize(0);
while (*p && (*p != '/') && (*p != ';') &&
(*p != '?') && (*p != '#') && (*p != '&')) s += *p++;
}
else
{
//这是一个不带反斜线的纯文件名,或者它只是一个主机名。
if (*p != '/') RelativePath = Host.empty();
else {
p++;
while (*p && (*p != '/') && (*p != ';') &&
(*p != '?') && (*p != '#') && (*p != '&')) s += *p++;
}
}

//只要当前字后跟有反斜线,就把它追加到路径后。

while (*p == '/')
{
p++;
//if (s.length())
Path.push_back(s); // uri可为'...//...'
s.resize(0);
while (*p && (*p != '/') && (*p != ';') &&
(*p != '?') && (*p != '#') && (*p != '&')) s += *p++;
}

//现在当前字为文件名
File = s;

//
//获取文件类型
//
string::size_type pp = File.rfind('.');
if (pp != string::npos) {
FileType = File.substr(pp+1);
}

//寻找参数

if (*p == ';')
{
p++;
s.resize(0);
while (*p && (*p != '?') && (*p != '#') &&
(*p != '&')) s += *p++;
Params = s;
}

//寻找查询
//接受以'&'打头的查询
if (*p == '?' || *p == '&')
{
s = *p; //保存前导查询字符
p++;
while (*p && (*p != '#')) s += *p++;
Query = s;
}

//寻找片断(fragment)

if (*p == '#')
{
p++;
s.resize(0);
while (*p) s += *p++;
Fragment = s;
}
}

  如果使用流程的话,代码就会像下面这个样子:

class Url
{
string scheme, host, port, user, pass, uri, param, ankor;
string* head_token;
int last_pos, cur_pos;
char* url;

parse_url(char* param)
{
START_FLOW analyze_url();

url = param;
int len = strlen(url);
last_pos = 0;
cur_pos = 0;
head_token = NULL;

while (cur_pos < len) {
cur_pos++;
}
if (head_token)
*head_token = url + last_pos;
}

void analyze_url()
{
START_FLOW
{
read_to_tail(&scheme, "://");

START_FLOW
read_from_head(&host, "/");

START_FLOW
read_from_head(&port, ":");

START_FLOW
{
string tmp;
read_from_head(&tmp, "@");

user = host;
pass = port;
host.erase();
port.erase();

read_from_head(&port, ":");
host = tmp;
}
}

START_FLOW
{
read_from_head(&uri, "/"));
START_FLOW
read_from_head(¶m, "?");
START_FLOW
read_from_head(&anchor, "#");
}
}

void read_to_tail(string* token, char* end_str)
{
head_token = token;
while (TRUE)
{
WAIT (cur_pos=);
if (memcmp(url + cur_pos, end_str, strlen(end_str)) == 0)
break;
}

head_token->assign(url + last_pos, cur_pos - last_pos);
last_pos = cur_pos = cur_pos + strlen(end_str);
head_token = NULL;
}

void read_from_head(string* token, char* start_str)
{
while (TRUE)
{
WAIT (cur_pos=);
if (memcmp(url + cur_pos, end_str, strlen(end_str)) == 0)
break;
}
if (head_token)
head_token->assign(url + last_pos, cur_pos - last_pos);

head_token = token;
last_pos = cur_pos + 1;
}
};

  代码短多了,也易于修改,面对更复杂的格式也更具可伸缩性。
阅读(245) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~