shardworker
2016-10-30 11:03:03 0 举报
ShardWorker是一种分布式计算模型,它将大型数据集分割成多个较小的部分,并将这些部分分配给多台计算机进行处理。这种模型可以提高数据处理的速度和效率,因为它允许多台计算机同时处理数据,而不是等待一台计算机完成所有工作。ShardWorker通常用于处理大量数据,如搜索引擎的索引、社交网络的用户数据等。在ShardWorker模型中,每台计算机都负责处理一部分数据,这被称为一个“分片”。当所有分片都处理完毕后,结果会被合并并返回给用户。ShardWorker模型的一个关键挑战是如何有效地将数据分配给多台计算机,以确保所有计算机都能充分利用其处理能力。
作者其他创作
大纲/内容
ShardWorker
- mShards
- entry()- Init()+ PushShard(Shard* shard)+ GetShardModule(ywb_uint32_t shardid) const
Thread
- thread_id
# entry()- _entry_func(void *arg)+ get_thread_id()+ is_started()+ am_self()+ kill(int signal)+ cancel()+ create(bool detach = false)+ join(void **prval = 0)+ detach()
DBWorker
# mDBMeta# mSelfSID# mReqQueue# mPersistProcessor# mCallBacks
+ PostRequest(IRequest *req)+ GetSelfSID() const+ GetPersistProcessor()+ GetCallBacks()+ SetDBMeta(DBMeta *meta)+ GetDBMeta()+ Start()
0 条评论
下一页
为你推荐
查看更多