在web應用中的彈簧線程

Question

我正在爲MMO瀏覽器遊戲編寫服務器，並且我需要製作幾個線程。 他們會在一段時間的睡眠中運行。 使用這樣的彈簧線是好主意嗎？

@Component 
@Scope("prototype") 
public class PrintTask2 implements Runnable{ 

String name; 

public void setName(String name){ 
    this.name = name; 
} 

@Override 
public void run() { 

    System.out.println(name + " is running"); 

    try { 
     Thread.sleep(5000); 
    } catch (InterruptedException e) { 
     e.printStackTrace(); 
    } 

    System.out.println(name + " is running"); 

} 

}

與任務執行器實現爲豆？

<bean id="taskExecutor" 
     class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor"> 
    <property name="corePoolSize" value="5" /> 
    <property name="maxPoolSize" value="10" /> 
    <property name="WaitForTasksToCompleteOnShutdown" value="true" /> 
</bean> 

此外，線程也是以singleton啓動的，也被定義爲一個bean。

我的方法有什麼問題？

Answer 1

您可以使用@Scheduled(fixedDelay = 5000)定期執行方法。請記得爲包含主要方法的類設置@EnableScheduling。

@Scheduled註釋有兩個選項 - fixedDelay和fixedRate。

fixedDelay將在上次執行完成後延遲X毫秒的時間繼續執行您的方法。

fixedRate將在固定的日期持續執行您的方法。因此，無論最後一次執行完成，每X毫秒該方法都將被執行。

如果您想一次處理大量對象，也可以使用@Async。再一次，您需要使用主要方法將@EnableAsync添加到您的課程中。

例

//Remember to set @EnableScheduling 
//in the class containing your main method 
@SpringBootApplication 
@EnableScheduling 
@EnableAsync 
public class Application { 

    public static void main(String[] args) throws Exception { 
     SpringApplication.run(Application.class); 
    } 
} 

@Component 
public class ScheduledTasks { 

List<YourObject> myObjects; 

    //This method will run every 5 second. 
    @Scheduled(fixedDelay = 5000) 
    public void yourMethodName() { 
     //This will process all of your objects all at once using treads 
     for(YourObject yo : myObjects){ 
      yo.process(); 
     } 
    } 
} 

public class YourObject { 

    Integer someTest = 0; 

    @Async 
    public void process() { 
     someTest++; 
    } 
} 

獎金 您可以通過擴展AsyncConfigurerSupport並覆蓋getAsyncExecutor擺脫對池大小的XML配置。有關此方法的更多信息可以在下面的鏈接中找到

我建議你看一看：

https://spring.io/guides/gs/scheduling-tasks/

https://spring.io/guides/gs/async-method/

Answer 2

您可以在使用的情況下，你@Async要調用一個單線程以編程方式（例如，您想發送50封郵件，併發送它們創建50個不同的線程，每個線程發送一條消息，然後等待所有線程結束），或@Scheduled讓方法/線程以固定速率運行（或之前執行結束後的一段時間）。

您可以關注https://docs.spring.io/spring/docs/current/spring-framework-reference/html/scheduling.html#scheduling-annotation-support瞭解更多詳情。

@Service 
public class MyAsyncStuff { 
    @Async 
    public Future<String> callMe(String param) { 
     // do your work here...   
     return new AsyncResult<String>("Sent: "+param);   
    } 
} 

@Service 
public class MyWorker { 
    @Inject 
    MyAsyncStuff stuff; 

    public void invoker() { 
     List<Future<String>> futures = new Arraylist<>(); 
     for (int i=0; i<10; i++) { 
      futures.add(stuff.callMe("Invoked "+i)); 
     } 
     for (Future<String> fut : futures) { 
      try { 
       System.out.println(futures.get(); 
      } catch (Exception e) { 
      // Spock? Do something! 
      } 
     } 
    } 
}