0

Есть такой код:

public class send_data {
    Socket s;
    PrintWriter printWriter;

    public void send(String message, String ip)
    {
        try {
            s = new Socket(ip, 1000);
            printWriter = new PrintWriter(s.getOutputStream());
            printWriter.write(message);
            printWriter.flush();
            printWriter.close();
            s.close();
        }catch (IOException e){

        }
    }

}

Он просто подключается к серверу и скидывает туда что-нибудь.

Суть в чём: есть 4 кнопки. Нужно сделать так, чтобы если нажать 2 кнопки одновременно - чтобы не было такого, что "кто успел - того и тапки", то есть, если нажаты обе одновременно - они вставали в очередь.

Если нажать 1 кнопку, а затем очень быстро вторую - чтобы программа дождалась, пока выполнится отправка сообщения от первой кнопки по сокету, а потом уже от второй.

Слышал, что можно сделать через newSingleThreadExecutor(), но не могу понять, как это сделать.

2 ответа 2

0

Попробуй так:

public class MyActivity extends Activity implements View.OnClickListener {

private static Thread thread;

private Handler handler;

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity);
    findViewById(R.id.button1).setOnClickListener(this);
    findViewById(R.id.button2).setOnClickListener(this);
    handler = new Handler();
}

@Override
public void onClick(View view) {
    int id = view.getId();
    switch(id) {
        case R.id.button1:
            button1();
            break;

        case R.id.button2:
            button2();
            break;
    }
}

private void button1() {
    final Thread oldThread = thread;
    Runnable runnable = new Runnable() {

        @Override
        public void run() {
            // ожидание завершения предыдущего потока
            if (oldThread != null) {
                while (oldThread.isAlive()) {
                    Thread.yield();
                }
            }
            // отправка 1 сообщения по сокету
            /* если требуется обращение к UI
            handler.post(new Runnable() {

                @Override
                public void run() {
                    // обращение к UI
                }
            });*/
        }
    };
    thread = new Thread(runnable);
    thread.setPriority(Thread.MIN_PRIORITY);
    thread.start();
}

private void button2() {
    final Thread oldThread = thread;
    Runnable runnable = new Runnable() {

        @Override
        public void run() {
            // ожидание завершения предыдущего потока
            if (oldThread != null) {
                while (oldThread.isAlive()) {
                    Thread.yield();
                }
            }
            // отправка 2 сообщения по сокету
            /* если требуется обращение к UI
            handler.post(new Runnable() {

                @Override
                public void run() {
                    // обращение к UI
                }
            });*/
        }
    };
    thread = new Thread(runnable);
    thread.setPriority(Thread.MIN_PRIORITY);
    thread.start();
}

}
0

Попробуйте с помощью newFixedThreadPool():

public class send_data {
    Socket s = null;
    PrintWriter printWriter = null;
    ExecutorService executor = Executors.newFixedThreadPool(1);

    public void send(String message, String ip)
    {
      Future<Void> future = executor.submit(() -> {
         try {
            s = new Socket(ip, 1000);
            printWriter = new PrintWriter(s.getOutputStream());
            printWriter.write(message);
            printWriter.flush();
         } catch (IOException ignored){}    
         catch (InterruptedException e) {
          throw new IllegalStateException("task interrupted", e);
         }
         finally {
           if (printWriter != null)
              printWriter.close();
           if (s != null)
              s.close();
         }
      });
      future.get();       
    }
}
1
  • 1
    Добавлю, что если данный метод вызывать в основном потоке, то нажать на вторую кнопку не получится, пока не выполнится future.get() (если IDE не распознает здесь NetworkOnMainThreadException), поэтому либо метод нужно вызывать в другом потоке(что странно), либо просто submit`ить Runnable без ожидания его исполнения с помощью Future.
    – AseN
    11 авг 2018 в 18:26

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими пользовательским соглашением, политикой конфиденциальности и политикой о куки

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.