Многопоточность Java без основного метода

Question

Я новичок в Java. У меня есть функция, где я хочу, чтобы функция выполняла многопоточное поведение. Проблема в том, что я буду делать банку без основного метода внутри нее. Просто хотел знать что мы можем иметь многопоточную функцию в Java без класса, имеющего основной метод? У меня есть следующий код, и я хочу, чтобы эта функция «myHandler» имела многопоточное поведение, так что всякий раз, когда эта функция вызывается, разные потоки выполняют ее ... Можете ли вы мне помочь, чтобы этот код выполнял многопоточное поведение? Спасибо

public String myHandler(KinesisEvent kinesisEvent,Context context) 
{ 
    int singleRecord=0; 
    long starttime=System.currentTimeMillis(); 
    //LambdaLogger lambdaLogger=context.getLogger(); 
    for(KinesisEventRecord rec : kinesisEvent.getRecords()) 
    { 
     singleRecord=0; 
     System.out.println("Kinesis Record inside is:"+new String(rec.getKinesis().getData().array())); 
     //count++; 
     singleRecord++; 
     // System.out.println(new String(rec.getKinesis().getData().array())); 
    } 
    count=count+singleRecord; 
    long endtime=System.currentTimeMillis(); 
    long totaltime = endtime-starttime; 
    time=time+totaltime; 
    System.out.println("Time required to execute single Lambda function for "+singleRecord+" records is"+" :: "+totaltime+" milliseconds"); 
    System.out.println("Total time required to execute Lambda function for "+count+" records is"+" :: "+time+" milliseconds"); 
    return null; 
} 

Answer 1

Я не уверен, что если это именно то, что вы хотите, но вы могли бы сделать что-то вроде этого:

public String myHandler(final KinesisEvent kinesisEvent, final Context context) 
{ 
    Thread thread = new Thread(new Runnable(){ 

     @Override 
     public void run() { 
      int singleRecord=0; 
      long starttime=System.currentTimeMillis(); 
      //LambdaLogger lambdaLogger=context.getLogger(); 
      for(KinesisEventRecord rec : kinesisEvent.getRecords()) 
      { 
       singleRecord=0; 
       System.out.println("Kinesis Record inside is:"+new String(rec.getKinesis().getData().array())); 
       //count++; 
       singleRecord++; 
       // System.out.println(new String(rec.getKinesis().getData().array())); 
      } 
      count=count+singleRecord; 
      long endtime=System.currentTimeMillis(); 
      long totaltime = endtime-starttime; 
      time=time+totaltime; 
      System.out.println("Time required to execute single Lambda function for "+singleRecord+" records is"+" :: "+totaltime+" milliseconds"); 
      System.out.println("Total time required to execute Lambda function for "+count+" records is"+" :: "+time+" milliseconds"); 
     } 
    }); 
    thread.start(); 
} 

Этот код будет начать свой код в новом потоке после вызова метода, но любые параметры, которые вы хотите использовать в теме должны быть Декабре lared final будет отображаться в анонимной реализации Runnable.

Другим решением было бы создать новый класс и расширить Thread класс:

public class MyHandlerThread extends Thread { 
    KinesisEvent kinesisEvent; 
    Context context; 

    public MyHandlerThread(KinesisEvent kinesisEvent, Context context) { 
     super(); 
     this.kinesisEvent = kinesisEvent; 
     this.context = context; 
    } 

    @Override 
    public void run() { 
     int singleRecord = 0; 
     long starttime = System.currentTimeMillis(); 
     //LambdaLogger lambdaLogger=context.getLogger(); 
     for (KinesisEventRecord rec : kinesisEvent.getRecords()) { 
      singleRecord = 0; 
      System.out.println("Kinesis Record inside is:" + new String(rec.getKinesis().getData().array())); 
      //count++; 
      singleRecord++; 
      // System.out.println(new String(rec.getKinesis().getData().array())); 
     } 
     count = count + singleRecord; 
     long endtime = System.currentTimeMillis(); 
     long totaltime = endtime - starttime; 
     time = time + totaltime; 
     System.out.println("Time required to execute single Lambda function for " + singleRecord + " records is" + " :: " + totaltime + " milliseconds"); 
     System.out.println("Total time required to execute Lambda function for " + count + " records is" + " :: " + time + " milliseconds"); 
    } 

} 

Для того, чтобы начать это как нить вы должны создать экземпляр объекта и вызвать его метод запуска.

MyHandlerThread thread = new MyHandlerThread(param1, param2); 
thread.start(); 

Надеется, что это помогает (:

Answer 2

Если метод всегда должен быть выполнен в отдельном потоке, вы можете создать тему и назовите код из этого потока по следующим образом:

public String myHandler(final KinesisEvent kinesisEvent, final Context context) { 
     new Thread(new Runnable() { 
      public void run() { 
       int singleRecord = 0; 
       long starttime = System.currentTimeMillis(); 
       //LambdaLogger lambdaLogger=context.getLogger(); 
       for (KinesisEventRecord rec : kinesisEvent.getRecords()) { 
        singleRecord = 0; 
        System.out.println("Kinesis Record inside is:" + new String(rec.getKinesis().getData().array())); 
        //count++; 
        singleRecord++; 
        // System.out.println(new String(rec.getKinesis().getData().array())); 
       } 
       count = count + singleRecord; 
       long endtime = System.currentTimeMillis(); 
       long totaltime = endtime - starttime; 
       time = time + totaltime; 
       System.out.println("Time required to execute single Lambda function for " + singleRecord + " records is" + " :: " + totaltime + " milliseconds"); 
       System.out.println("Total time required to execute Lambda function for " + count + " records is" + " :: " + time + " milliseconds"); 
       return null; 
      } 
     }).start(); 
    }