Mãos à Obra: Aprendizado de Máquina com Scikit-Learn e TensorFlow

Vários Dispositivos em Vários Servidores | 345

Puxe um minilote inteiro ao mesmo tempo em vez de apenas uma instância por vez

utilizando uma operação dequeue_many especificando o tamanho do minilote:

[...]

batch_size =

2

dequeue_mini_batch = q.dequeue_many(batch_size)

with tf.Session("grpc://machine-a.example.com:2222") as sess:

print(sess.run(dequeue_mini_batch)) # [[1., 2.], [4., 5.]]

print(sess.run(dequeue_mini_batch)) # bloqueado esperando por outra instância

A operação enqueue [enfileiramento] será bloqueada até que os itens sejam removidos

por uma operação dequeue [desenfileiramento] quando uma fila estiver cheia. Da mesma

forma, quando uma ...