FLCommunicator¶

class paddle.fluid.communicator. FLCommunicator ( ps_hosts, kwargs=None ) [source]

is_running ( )

is_running¶

Get communicator is running or stop.

Returns

bool

Examples

import paddle.fluid as fluid

prog = fluid.Program()
comm = fluid.communicator.Communicator(prog)
comm.is_running()

start ( )

start¶

Start communicator. Should call before training process.

Returns

None

Examples

import paddle.fluid as fluid

prog = fluid.Program()
comm = fluid.communicator.Communicator(prog)
comm.start()
comm.stop()

stop ( )

stop¶

Stop communicator. Should call after training process.

Returns

None

Examples

import paddle.fluid as fluid

prog = fluid.Program()
comm = fluid.communicator.Communicator(prog)
comm.start()
comm.stop()