[rllib] Queue lib for python 2.7 (#2057)

* Queue lib for python 2.7

* use six.moves.queue instead
This commit is contained in:
alexbao
2018-05-16 06:27:52 +08:00
committed by Richard Liaw
parent 3f1dd29eab
commit 68bec0f6fb
@@ -7,12 +7,12 @@ from __future__ import division
from __future__ import print_function
import os
import queue
import random
import time
import threading
import numpy as np
from six.moves import queue
import ray
from ray.rllib.optimizers.policy_optimizer import PolicyOptimizer
@@ -22,6 +22,7 @@ from ray.rllib.utils.actors import TaskPool, create_colocated
from ray.rllib.utils.timer import TimerStat
from ray.rllib.utils.window_stat import WindowStat
SAMPLE_QUEUE_DEPTH = 2
REPLAY_QUEUE_DEPTH = 4
LEARNER_QUEUE_MAX_SIZE = 16