Skip to content

Commit df917f6

Browse files
author
Han Wang
committed
set the inter_op_parallelism_threads at the first session created by the process
1 parent dbe3fc1 commit df917f6

File tree

1 file changed

+9
-2
lines changed

1 file changed

+9
-2
lines changed

source/train/Model.py

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -625,7 +625,11 @@ def compute_dstats_sys_smth (self,
625625
sel_a = self.sel_a,
626626
sel_r = self.sel_r)
627627
# self.sess.run(tf.global_variables_initializer())
628-
sub_sess = tf.Session(graph = sub_graph)
628+
sub_sess = tf.Session(graph = sub_graph,
629+
config=tf.ConfigProto(intra_op_parallelism_threads=self.run_opt.num_intra_threads,
630+
inter_op_parallelism_threads=self.run_opt.num_inter_threads
631+
632+
))
629633
dd_all = sub_sess.run(descrpt)
630634
sub_sess.close()
631635
natoms = natoms_vec
@@ -682,7 +686,10 @@ def compute_dstats_sys_nonsmth (self,
682686
sel_r = self.sel_r,
683687
axis_rule = self.axis_rule)
684688
# self.sess.run(tf.global_variables_initializer())
685-
sub_sess = tf.Session(graph = sub_graph)
689+
sub_sess = tf.Session(graph = sub_graph,
690+
config=tf.ConfigProto(intra_op_parallelism_threads=self.run_opt.num_intra_threads,
691+
inter_op_parallelism_threads=self.run_opt.num_inter_threads
692+
))
686693
dd_all = sub_sess.run(descrpt)
687694
sub_sess.close()
688695
natoms = natoms_vec

0 commit comments

Comments
 (0)