create.sink(rzmq)
create.sink()所属R语言包:rzmq
create a sink object.
创建一个接收器对象。
译者:生物统计家园网 机器人LoveR
描述----------Description----------
Create a sink object in a separate thread which acts as an async reciever for remotely executed jobs.
在一个单独的线程创建一个接收器对象作为一个异步远程执行工作的reciever。
The job results can be later retreived via get.sink.results.
作业结果,可后来retreived通过get.sink.results。
用法----------Usage----------
create.sink(address, num_items)
get.sink.results(sink)
参数----------Arguments----------
参数:address
the transport endpoint for the remote sink server.
宿服务器的远程传输端点。
参数:num_items
the number of items to indicate the remote job has completed.
的项目数,以指示远程作业已完成。
参数:sink
the sink object.
接收器对象。
值----------Value----------
create.sink returns a sink object get.sink.results returns a list of the remotely executed jobs
create.sink返回水槽的对象get.sink.results返回一个列表中的远程执行工作
(作者)----------Author(s)----------
ZMQ was written by Martin Sustrik <sustrik@250bpm.com> and Martin Lucina <mato@kotelna.sk>.
rzmq was written by Whit Armstrong.
参考文献----------References----------
http://www.zeromq.org http://api.zeromq.org http://zguide.zeromq.org/page:all
参见----------See Also----------
connect.socket,bind.socket,receive.socket,send.socket
connect.socket,bind.socket,receive.socket,send.socket
实例----------Examples----------
## an example in the spirit of lapply[#lapply的精神,例如在]
x <- as.list(1:100)
context = init.context()
execution.socket = init.socket(context,"ZMQ_PUSH")
connect.socket(execution.socket,"tcp://my.remote.server:5557")
## listen for results[#监听结果]
N <- length(x)
sink <- create.sink("tcp://my.results.server:5558",N)
for(i in 1:N) {
remote.exec(execution.socket,FUN,x[[i]])
}
ans <- get.sink.results(sink)
lapply(ans,unserialize)
转载请注明:出自 生物统计家园网(http://www.biostatistic.net)。
注:
注1:为了方便大家学习,本文档为生物统计家园网机器人LoveR翻译而成,仅供个人R语言学习参考使用,生物统计家园保留版权。
注2:由于是机器人自动翻译,难免有不准确之处,使用时仔细对照中、英文内容进行反复理解,可以帮助R语言的学习。
注3:如遇到不准确之处,请在本贴的后面进行回帖,我们会逐渐进行修订。
|