Displaying 5 results from an estimated 5 matches for "mckill".
Did you mean:
mcgill
2015 Mar 25
2
nested parallel workers
...ld run 'forever' but terminates semi-randomly
library(parallel)
children <- parallel:::children
while (TRUE) {
n <- 8 ## n == dectectCores()
jobs <- lapply(seq_len(n), function(i) mcparallel(Sys.sleep(20)))
mccollect(children(jobs), FALSE)
parallel:::mckill(children(jobs), tools::SIGTERM)
leni <- length(mccollect(children(jobs)))
message("leni: ", leni)
}
~/tmp >R-dev --vanilla --slave -f test1.R
leni: 6
leni: 7
leni: 7
leni: 7
leni: 7
leni: 7
leni: 7
leni: 7
leni: 8
leni: 7
leni: 7
leni: 7
~/tmp >
Thanks.
Valerie
&g...
2015 Mar 30
2
nested parallel workers
...ary(parallel)
>> children <- parallel:::children
>>
>> while (TRUE) {
>> n <- 8 ## n == dectectCores()
>> jobs <- lapply(seq_len(n), function(i) mcparallel(Sys.sleep(20)))
>> mccollect(children(jobs), FALSE)
>> parallel:::mckill(children(jobs), tools::SIGTERM)
>> leni <- length(mccollect(children(jobs)))
>> message("leni: ", leni)
>> }
>>
>> ~/tmp >R-dev --vanilla --slave -f test1.R
>> leni: 6
>> leni: 7
>> leni: 7
>> leni: 7
>> leni: 7
>...
2012 Mar 23
1
serialization regression in 2.15.0 beta
...rns to the calling
environment.
Part of svn commit r58219 is this hunk
diff --git a/src/library/parallel/R/unix/mcfork.R
b/src/library/parallel/R/unix/mcfork.R
index 8e27534..4f92193 100644
--- a/src/library/parallel/R/unix/mcfork.R
+++ b/src/library/parallel/R/unix/mcfork.R
@@ -82,7 +82,8 @@ mckill <- function(process, signal = 2L)
## used by mcparallel, mclapply
sendMaster <- function(what)
{
- if (!is.raw(what)) what <- serialize(what, NULL, FALSE)
+ # This is talking to the same machine, so no point in using xdr.
+ if (!is.raw(what)) what <- serialize(what, NULL,...
2015 Mar 26
0
nested parallel workers
...minates semi-randomly
> library(parallel)
> children <- parallel:::children
>
> while (TRUE) {
> n <- 8 ## n == dectectCores()
> jobs <- lapply(seq_len(n), function(i) mcparallel(Sys.sleep(20)))
> mccollect(children(jobs), FALSE)
> parallel:::mckill(children(jobs), tools::SIGTERM)
> leni <- length(mccollect(children(jobs)))
> message("leni: ", leni)
> }
>
> ~/tmp >R-dev --vanilla --slave -f test1.R
> leni: 6
> leni: 7
> leni: 7
> leni: 7
> leni: 7
> leni: 7
> leni: 7
> leni: 7
>...
2015 Mar 30
0
nested parallel workers
...; children <- parallel:::children
>>>
>>> while (TRUE) {
>>> n <- 8 ## n == dectectCores()
>>> jobs <- lapply(seq_len(n), function(i) mcparallel(Sys.sleep(20)))
>>> mccollect(children(jobs), FALSE)
>>> parallel:::mckill(children(jobs), tools::SIGTERM)
>>> leni <- length(mccollect(children(jobs)))
>>> message("leni: ", leni)
>>> }
>>>
>>> ~/tmp >R-dev --vanilla --slave -f test1.R
>>> leni: 6
>>> leni: 7
>>> leni: 7
>&g...