htr commited on
Commit
de59685
·
1 Parent(s): 3e1f7fc
src/main/java/com/example/demo/DemoApplication.java CHANGED
@@ -37,7 +37,8 @@ import tqtk.Utils.Util;
37
  import tqtk.XuLy.Worker;
38
  import tqtk.XuLy.XuLyPacket;
39
  import tqtk.XuLy.login.LayThongTinSession;
40
-
 
41
  @SpringBootApplication
42
  @RestController
43
  public class DemoApplication {
@@ -100,8 +101,12 @@ public class DemoApplication {
100
  @ResponseBody
101
  public String resumeAll() throws IOException, UnknownHostException, InterruptedException, Exception {
102
  try {
 
 
103
  for (int i = 0; i < Tqtk.listWorker.size(); ++i) {
104
  synchronized (Tqtk.listWorker.get(i).lock) {
 
 
105
  Tqtk.listWorker.get(i).isStop = false;
106
  Tqtk.listWorker.get(i).lock.notify();
107
  }
 
37
  import tqtk.XuLy.Worker;
38
  import tqtk.XuLy.XuLyPacket;
39
  import tqtk.XuLy.login.LayThongTinSession;
40
+ import java.util.ArrayList;
41
+ import java.util.Collections;
42
  @SpringBootApplication
43
  @RestController
44
  public class DemoApplication {
 
101
  @ResponseBody
102
  public String resumeAll() throws IOException, UnknownHostException, InterruptedException, Exception {
103
  try {
104
+ Tqtk.listSession = new ArrayList<>();
105
+ Tqtk.listSession = Collections.synchronizedList(Tqtk.listSession);
106
  for (int i = 0; i < Tqtk.listWorker.size(); ++i) {
107
  synchronized (Tqtk.listWorker.get(i).lock) {
108
+ Tqtk.listWorker.get(i).setSs(Tqtk.listSession.get(i));
109
+ Tqtk.listWorker.get(i).createSocket(Tqtk.listSession.get(i));
110
  Tqtk.listWorker.get(i).isStop = false;
111
  Tqtk.listWorker.get(i).lock.notify();
112
  }