Julia - Transferring methods between workers -

-

i've been using sendto() method send variables between workers

i under impression in julia, functions 'first class citizens', cannot transfer functions between workers using sendto() method

what recommended way of transferring predefined methods between workers?

update

i seem able use sendto() method send anonymous functions

a = function(x) x*2 end  sendto(2,a=a)  remotecall_fetch(2,a,5) 4

as opposed to

function g(x) x*2 end  sendto(2,g=g)  remotecall_fetch(2,g,10) error: on worker 2: function g not defined on process 2

this suffices in cases, need able send defined functions over, of them complex , defined in scripts included when starting julia

there no way send subset of methods in package machine. methods refer other types , functions in same module, system have @ least send dependencies well. work, bigger problem deciding responsibility distribute code, , when. example, library might decide send (or parts of itself) other nodes, user might later want parallel map of library functions, such whole library needed on every node. gets complex, far simpler load needed code on nodes possible.

it factor code smaller modules. code defines reusable functions should wrapped in module separate "real work", loading not take significant time.

if code loaded on client node needs different what's loaded on workers, can put definitions need sent in own module, helpers. main code contain using helpers. after code loaded on client node, can start workers , run @everywhere include("helpers.jl") suggested chris. references functions inside helpers should work across machines.


Comments

Post a Comment

Popular posts from this blog

Spring Boot + JPA + Hibernate: Unable to locate persister -

-
i trying work entity inside request method of spring boot application. entity in project , pom.xml has dependencies it. why error message?: org.hibernate.unknownentitytypeexception: unable locate persister: com.ric.bill.model.bs.par package com.ric.web; import java.util.concurrent.atomic.atomiclong; import javax.persistence.entitymanager; import javax.persistence.persistencecontext; import net.sf.ehcache.cachemanager; import net.sf.ehcache.management.cache; import net.sf.ehcache.management.cachestatistics; import org.hibernate.stat.statistics; import org.springframework.beans.factory.annotation.autowired; import org.springframework.boot.autoconfigure.domain.entityscan; import org.springframework.cache.annotation.enablecaching; import org.springframework.transaction.annotation.enabletransactionmanagement; import org.springframework.transaction.annotation.propagation; import org.springframework.transaction.annotation.transactional; import org.springframework.web.bind.annotati
Read more

go - Golang: panic: runtime error: invalid memory address or nil pointer dereference using bufio.Scanner -

-
i implementing go program uses bufio.scanner , bufio.writer have packaged code follows package main import ( "fmt" "player/command" "strings" ) func main() { //enter code here. read input stdin. print output stdout commands.scanner.scan() { //scan new line , send comand variable check command exist or not input := strings.split(strings.trim(commands.scanner.text(), " "), " ") command := input[0] if command == "" { fmt.printf("$ %s:", commands.pwd) continue } if !commands.commands[command] { commands.throwerror("cannot recognize input.") } else { commands.execute(command, input[1:], nil) } fmt.printf("$ %s:", commands.pwd) } } i using init.go file in main package follows package main import ( "flag" "player/sourc
Read more

c - double free or corruption (fasttop) -

-
this code reads null terminated string file (file containing null terminated strings & should provide index wanted string). error: *** error in `./main': double free or corruption (fasttop): 0x090a4a80 *** aborted code: char *tmp_realloc=null; char *sstring=null; int i=1; /*set file pointer point string*/ fseek(fh,index,seek_set); sstring=(char*)malloc(sizeof(char)); if(sstring == null) return null; tmp_realloc=sstring; while( (*(sstring+i-1)=(char)fgetc((file*)fh)) != 0x0 ) { /*reallocate more memory*/ tmp_realloc=(char*)realloc((char*)sstring,++i); /*if not same address copy old new & set old point new*/ if(tmp_realloc != sstring){ strcpy((char*)tmp_realloc,(char*)sstring); free(sstring); sstring=tmp_realloc; } } could tell me pointer causing issue (& reason) ? remove part /*if not same address copy old new & set old point new*/ if(tmp_realloc != sstring){ strc
Read more