import tensorflow as tf

import tensorlayer as tl

import gym

import numpy as np

import time

image_size = 80

D = image_size * image_size

H = 200

batch_size = 10

learning_rate = 1e-4

gamma = 0.99

decay_rate = 0.99

render = False # display the game environment

resume = False # load existing policy network

model_file_name = "model_pong"

np.set_printoptions(threshold=np.nan)

def prepro(I):

return I.astype(np.float).ravel()

env = gym.make("Pong-v0")

observation = env.reset()

prev_x = None

running_reward = None

reward_sum = 0

episode_number = 0

xs, ys, rs = [], [], []

states_batch_pl = tf.placeholder(tf.float32, shape=[None, D])

network = tl.layers.InputLayer(states_batch_pl, name='input_layer')

network = tl.layers.DenseLayer(network, n_units=H,

act = tf.nn.relu, name='relu1')

network = tl.layers.DenseLayer(network, n_units=3,

act = tf.identity, name='output_layer')

probs = network.outputs

sampling_prob = tf.nn.softmax(probs)

actions_batch_pl = tf.placeholder(tf.int32, shape=[None])

discount_rewards_batch_pl = tf.placeholder(tf.float32, shape=[None])

loss = tl.rein.cross_entropy_reward_loss(probs, actions_batch_pl,

discount_rewards_batch_pl)

train_op = tf.train.RMSPropOptimizer(learning_rate, decay_rate).minimize(loss)

with tf.Session() as sess:

# init = tf.initialize_all_variables()

# sess.run(init)

tl.layers.initialize_global_variables(sess)

if resume:

load_params = tl.files.load_npz(name=model_file_name+'.npz')

tl.files.assign_params(sess, load_params, network)

network.print_params()

network.print_layers()

start_time = time.time()

game_number = 0

while True:

if render: env.render()

cur_x = prepro(observation)

x = cur_x - prev_x if prev_x is not None else np.zeros(D)

x = x.reshape(1, D)

prev_x = cur_x

prob = sess.run(

sampling_prob,

feed_dict={states_batch_pl: x}

)

# action. 1: STOP 2: UP 3: DOWN

action = np.random.choice([1,2,3], p=prob.flatten())

observation, reward, done, _ = env.step(action)

reward_sum += reward

xs.append(x) # all observations in a episode

ys.append(action - 1) # all fake labels in a episode (action begins from 1, so minus 1)

rs.append(reward) # all rewards in a episode

if done:

episode_number += 1

game_number = 0

if episode_number % batch_size == 0:

print('batch over...... updating parameters......')

epx = np.vstack(xs)

epy = np.asarray(ys)

epr = np.asarray(rs)

disR = tl.rein.discount_episode_rewards(epr, gamma)

disR -= np.mean(disR)

disR /= np.std(disR)

xs, ys, rs = [], [], []

sess.run(

train_op,

feed_dict={

states_batch_pl: epx,

actions_batch_pl: epy,

discount_rewards_batch_pl: disR

}

)

if episode_number % (batch_size * 100) == 0:

tl.files.save_npz(network.all_params, name=model_file_name+'.npz')

running_reward = reward_sum if running_reward is None else running_reward * 0.99 + reward_sum * 0.01

print('resetting env. episode reward total was %f. running mean: %f' % (reward_sum, running_reward))

reward_sum = 0

observation = env.reset() # reset env

prev_x = None

if reward != 0:

print(('episode %d: game %d took %.5fs, reward: %f' %

(episode_number, game_number,

time.time()-start_time, reward)),

('' if reward == -1 else ' !!!!!!!!'))

start_time = time.time()

game_number += 1