Фрагмент: приложение может слишком много работать над своим основным потоком.

Я использую в своем приложении 3-й фрагмент. Когда я перехожу к 3.fragment, я хочу отправить сообщение другим устройствам с Bluetooth. Но в моем журнале сказано:

Приложение может слишком много работать со своим основным потоком.

И чем моя блокировка AcceptedThread. Итак, мой ConnectedThread пуст. Я не могу ничего отправить. Как я могу это исправить? Это мой код bluetoothservice:

public class BluetoothConnectionService {
    private static final String TAG = "BluetoothConnectionServ";

    private static final String appName = "MYAPP";

    private static final UUID MY_UUID_INSECURE =
            UUID.fromString("00001101-0000-1000-8000-00805F9B34FB");

    private final BluetoothAdapter mBluetoothAdapter;
    Context mContext;

    private AcceptThread mInsecureAcceptThread;

    private ConnectThread mConnectThread;
    private BluetoothDevice mmDevice;
    private UUID deviceUUID;
    ProgressDialog mProgressDialog;

    private ConnectedThread mConnectedThread;

    public BluetoothConnectionService(Context context) {
        mContext = context;
        mBluetoothAdapter = BluetoothAdapter.getDefaultAdapter();
        start();
    }


    /**
     * This thread runs while listening for incoming connections. It behaves
     * like a server-side client. It runs until a connection is accepted
     * (or until cancelled).
     */
    private class AcceptThread extends Thread {

        // The local server socket
        private final BluetoothServerSocket mmServerSocket;

        public AcceptThread(){
            BluetoothServerSocket tmp = null;

            // Create a new listening server socket
            try{
                tmp = mBluetoothAdapter.listenUsingInsecureRfcommWithServiceRecord(appName, MY_UUID_INSECURE);

                Log.d(TAG, "AcceptThread: Setting up Server using: " + MY_UUID_INSECURE);
            }catch (IOException e){
                Log.e(TAG, "AcceptThread: IOException: " + e.getMessage() );
            }

            mmServerSocket = tmp;
        }

        public void run(){
            Log.d(TAG, "run: AcceptThread Running.");

            BluetoothSocket socket = null;

            try{
                // This is a blocking call and will only return on a
                // successful connection or an exception
                Log.d(TAG, "run: RFCOM server socket start.....");

                socket = mmServerSocket.accept();
                Log.d(TAG, "run: RFCOM server socket accepted connection.");

            }catch (IOException e){
                Log.e(TAG, "AcceptThread: IOException: " + e.getMessage() );
            }

            //talk about this is in the 3rd
            if(socket != null){
                Log.d(TAG, "run: Connected is active");

                connected(socket,mmDevice);
            }

            Log.i(TAG, "END mAcceptThread ");
        }

        public void cancel() {
            Log.d(TAG, "cancel: Canceling AcceptThread.");
            try {
                mmServerSocket.close();
            } catch (IOException e) {
                Log.e(TAG, "cancel: Close of AcceptThread ServerSocket failed. " + e.getMessage() );
            }
        }

    }

    /**
     * This thread runs while attempting to make an outgoing connection
     * with a device. It runs straight through; the connection either
     * succeeds or fails.
     */
    private class ConnectThread extends Thread {
        private BluetoothSocket mmSocket;

        public ConnectThread(BluetoothDevice device, UUID uuid) {
            Log.d(TAG, "ConnectThread: started.");
            mmDevice = device;
            deviceUUID = uuid;
        }

        public void run(){
            BluetoothSocket tmp = null;
            Log.i(TAG, "RUN mConnectThread ");

            // Get a BluetoothSocket for a connection with the
            // given BluetoothDevice
            try {
                Log.d(TAG, "ConnectThread: Trying to create InsecureRfcommSocket using UUID: "
                        +MY_UUID_INSECURE );
                tmp = mmDevice.createRfcommSocketToServiceRecord(deviceUUID);
            } catch (IOException e) {
                Log.e(TAG, "ConnectThread: Could not create InsecureRfcommSocket " + e.getMessage());
            }

            mmSocket = tmp;

            // Always cancel discovery because it will slow down a connection
            mBluetoothAdapter.cancelDiscovery();

            // Make a connection to the BluetoothSocket

            try {
                // This is a blocking call and will only return on a
                // successful connection or an exception
                mmSocket.connect();

                Log.d(TAG, "run: ConnectThread connected.");
            } catch (IOException e) {
                // Close the socket
                try {
                    mmSocket.close();
                    Log.d(TAG, "run: Closed Socket.");
                } catch (IOException e1) {
                    Log.e(TAG, "mConnectThread: run: Unable to close connection in socket " + e1.getMessage());
                }
                Log.d(TAG, "run: ConnectThread: Could not connect to UUID: " + MY_UUID_INSECURE );
            }

            //will talk about this in the 3rd video

            connected(mmSocket,mmDevice);
        }
        public void cancel() {
            try {
                Log.d(TAG, "cancel: Closing Client Socket.");
                mmSocket.close();
            } catch (IOException e) {
                Log.e(TAG, "cancel: close() of mmSocket in Connectthread failed. " + e.getMessage());
            }
        }
    }



    /**
     * Start the chat service. Specifically start AcceptThread to begin a
     * session in listening (server) mode. Called by the Activity onResume()
     */
    public synchronized void start() {
        Log.d(TAG, "start");

        // Cancel any thread attempting to make a connection
        if (mConnectThread != null) {
            mConnectThread.cancel();
            mConnectThread = null;
        }

        if (mInsecureAcceptThread == null) {
            mInsecureAcceptThread = new AcceptThread();
            mInsecureAcceptThread.start();
        }
    }

    /**
     AcceptThread starts and sits waiting for a connection.
     Then ConnectThread starts and attempts to make a connection with the other devices AcceptThread.
     **/

    public void startClient(BluetoothDevice device,UUID uuid){
        Log.d(TAG, "startClient: Started.");

        //initprogress dialog
        mProgressDialog = ProgressDialog.show(mContext,"Connecting Bluetooth"
                ,"Please Wait...",true);

        mConnectThread = new ConnectThread(device, uuid);
        mConnectThread.start();
    }

    /**
     Finally the ConnectedThread which is responsible for maintaining the BTConnection, Sending the data, and
     receiving incoming data through input/output streams respectively.
     **/
    private class ConnectedThread extends Thread {
        private final BluetoothSocket mmSocket;
        private final InputStream mmInStream;
        private final OutputStream mmOutStream;

        public ConnectedThread(BluetoothSocket socket) {
            Log.d(TAG, "ConnectedThread: Starting.");

            mmSocket = socket;
            InputStream tmpIn = null;
            OutputStream tmpOut = null;

            //dismiss the progressdialog when connection is established
            try{
                mProgressDialog.dismiss();
            }catch (NullPointerException e){
                e.printStackTrace();
            }


            try {
                tmpIn = mmSocket.getInputStream();
                tmpOut = mmSocket.getOutputStream();
            } catch (IOException e) {
                e.printStackTrace();
            }

            mmInStream = tmpIn;
            mmOutStream = tmpOut;
        }

        public void run(){
            byte[] buffer = new byte[1024];  // buffer store for the stream

            int bytes; // bytes returned from read()

            // Keep listening to the InputStream until an exception occurs
            while (true) {
                // Read from the InputStream
                try {
                    bytes = mmInStream.read(buffer);
                    String incomingMessage = new String(buffer, 0, bytes);
                    Log.d(TAG, "InputStream: " + incomingMessage);
                    Intent incomingMessageIntent = new Intent("incomingMessage");

                    incomingMessageIntent.putExtra("theMessage", incomingMessage);
                    LocalBroadcastManager.getInstance(mContext).sendBroadcast(incomingMessageIntent);

                } catch (IOException e) {
                    Log.e(TAG, "write: Error reading Input Stream. " + e.getMessage() );
                    break;
                }
            }
        }







        //Call this from the main activity to send data to the remote device
        public void write(byte[] bytes) {
            String text = new String(bytes, Charset.defaultCharset());
            Log.d(TAG, "write: Writing to outputstream: " + text);
            try {
                mmOutStream.write(bytes);
            } catch (IOException e) {
                Log.e(TAG, "write: Error writing to output stream. " + e.getMessage() );
            }
        }

        /* Call this from the main activity to shutdown the connection */
        public void cancel() {
            try {
                mmSocket.close();
            } catch (IOException e) { }
        }
    }

    private void connected(BluetoothSocket mmSocket, BluetoothDevice mmDevice) {
        Log.d(TAG, "connected: Starting.");

        // Start the thread to manage the connection and perform transmissions
        mConnectedThread = new ConnectedThread(mmSocket);
        mConnectedThread.start();
    }

    /**
     * Write to the ConnectedThread in an unsynchronized manner
     *
     * @param out The bytes to write
     * @see ConnectedThread#write(byte[])
     */
    public void write(byte[] out) {
        // Create temporary object
        ConnectedThread r;
        if(mConnectedThread==null){
return;
        }
        // Synchronize a copy of the ConnectedThread
        Log.d(TAG, "write: Write Called.");
        //perform the write
        mConnectedThread.write(out);
    }

}

person CKocar    schedule 23.07.2018    source источник
comment
stackoverflow.com/questions/14678593/   -  person AskNilesh    schedule 23.07.2018
comment
я уже читал это   -  person CKocar    schedule 23.07.2018
comment
У меня много фрагментов. И фрагмент называют другим фрагментом. Это не правильно ? или не ?   -  person CKocar    schedule 23.07.2018
comment
У меня много фрагментов. И фрагмент называют другим фрагментом. Это неправильно Нет   -  person AskNilesh    schedule 23.07.2018
comment


Ответы (3)


У меня была эта ошибка давным-давно, когда я делал запросы на свой сервер. Я создал IntentService для обработки этих запросов, и эта проблема исчезла. Вот хороший пример, показывающий, как его создать!

Поместите сообщения, которые вы хотите отправить на другие устройства, в эту IntentService!

person Rodrigo Gontijo    schedule 23.07.2018
comment
У меня есть MainActivty, и я вызываю здесь signfragment, а затем я вызываю фрагмент списка bluetooth, а затем я вызываю еще один адаптер из трех фрагментов, поэтому я часто вызываю фрагмент во фрагменте. Это ошибка или нет? - person CKocar; 23.07.2018
comment
Нет, это не ошибка! Для этого созданы фрагменты! - person Rodrigo Gontijo; 23.07.2018
comment
Я новичок в Android, поэтому я не знаю, как я могу использовать intentservice в моем приложении, спасибо за вашу ссылку, я пытаюсь, надеюсь, на этот раз я исправлю: / - person CKocar; 23.07.2018
comment
Весь ваш код кажется правильным (я из мобильной версии, и его трудно хорошо читать на маленьком дисплее), однако ваш метод Service.write () напрямую выполняет метод Thread.write () вместо отправки сообщения / сигнала ( к этому потоку), чтобы он мог выполнить процедуру записи. Это основа взаимодействия потоков: каждая команда ASYNC должна быть уведомлена / поставлена ​​в очередь этому потоку вместо того, чтобы выполнять ее непосредственно из основного потока / потока пользовательского интерфейса. - person emandt; 23.07.2018
comment
На самом деле мой 2-й фрагмент получает значение для других устройств успешно, но 3-й фрагмент не может отправлять другие устройства, потому что servicejava блокирует этот журнал: приложение может слишком много работать в своем основном потоке. - person CKocar; 23.07.2018
comment
@emandt, вы правы, но вместо использования asyncTask лучше использовать IntentService, потому что он поставляется со встроенной Очередью заявок. - person Rodrigo Gontijo; 23.07.2018
comment
Опубликуйте свои результаты позже для нас! А если получится, не забудьте проголосовать и пометить как принятый! Увидимся. - person Rodrigo Gontijo; 23.07.2018
comment
Итак, для функции просто записи я создам IntentService, верно? или все сервисным методом Bluetooth? - person CKocar; 23.07.2018
comment
Я не предлагаю использовать AsyncTasks, которые представляют собой нечто совершенно иное. Я предлагаю использовать ОБЫЧНУЮ связь потоков с помощью сообщений. IntentServices будет включать в себя совершенно другую процедуру разработки, поэтому она более долгая и сложная (не так много, но ...) - person emandt; 23.07.2018
comment
Окей. Спасибо - person CKocar; 23.07.2018
comment
Как я могу сделать ? Я ищу эту ошибку в течение 3 дней, но не могу найти решения. - person CKocar; 23.07.2018
comment
stackoverflow.com/questions/51493431/ пожалуйста, проверьте мой новый вопрос - person CKocar; 24.07.2018
comment
Я жду принятия моего ответа здесь .... Я отвечаю 20 человек каждый день, но большинство из них не отмечает мои ответы, и это довольно неприятно. - person emandt; 24.07.2018
comment
Я жду принятия своего ответа здесь .... Я отвечаю 20 человек каждый день, но большинство из них не отмечает мои ответы, и это довольно неприятно (2) - person Rodrigo Gontijo; 24.07.2018

Вы можете создать службу с автоматическим остановом, когда ваша операция Bluetooth будет завершена. Не забудьте добавить службу в свой манифест. Начни так:

startService(new Intent(this, MyTemporaryService.class));

А вот и класс обслуживания:

public class MyTemporaryService extends Service {

@Nullable
@Override
public IBinder onBind(Intent intent) {
    return null;
}

@Override
public int onStartCommand(Intent intent, int flags, int startId) {

    return START_NOT_STICKY;

}

@Override
public void onCreate() {
    super.onCreate();

    try {

        Thread thread = new Thread(new Runnable() {

            @Override
            public void run() {

                // Execute you method in that background thread, so we do not block main thread.

                myCodeToExecute();

                // stop the service when myCodeToExecute method is finished;

                stopSelf();

            }

        });

        thread.start();

    } catch (Exception e) {

        stopSelf();

    } catch (Error e2) {

        stopSelf();

    }


}


}

И добавьте в свой манифест:

    <service android:name="com.myApp.MyTemporaryService" android:enabled="true"
    />
person Samet    schedule 23.07.2018
comment
Большое спасибо.Также мой сервис bluetooth не включен в файл манифеста, возможно, причиной этой проблемы является моя проблема. :) - person CKocar; 24.07.2018
comment
Если служба обычно отсутствует в манифесте, она сообщит вам об этом в logcat. Я плохо помню. Может, это связано с твоей проблемой. В любом случае предоставляемая мной услуга самоостановки должна работать. - person Samet; 24.07.2018
comment
вы можете помочь мне в этом вопросе? stackoverflow.com/questions/51556090 / - person CKocar; 27.07.2018

Проблема в том, что ваш "mConnectedThread.write (out);" выполняется не в потоке (как вы написали в комментарии), а в службе (которая использует / использует один и тот же поток графического интерфейса). Вы должны создать HandleThread и отправить ему сообщение, когда вы хотите выполнить действие «write ()».

person emandt    schedule 23.07.2018
comment
Да, я использую график. Как я могу использовать HandleThread на BluetoothService, пожалуйста, помогите мне. Спасибо - person CKocar; 23.07.2018
comment
Вы должны создать обработчик из потока, а затем использовать mHandler.sendMessge (Message.obtain (mHandler, TH_MESSAGE_WRITE, 0, 0, buffer)) из любого другого потока. Неявно внутри обработчика вы должны прочитать ранее отправленное сообщение, извлечь буфер и затем выполнить свой метод Thread.write (). Пример из другого проекта, но с тем же методом решения: stackoverflow .com / questions / 51458200 / - person emandt; 23.07.2018
comment
PS: из этой ссылки / примера НЕ используйте Looper.getMainLooper (), иначе вы попадете в ту же проблему, что и раньше. Просто используйте базовый new Handler () {} без явной установки Looper. - person emandt; 23.07.2018
comment
Я не могу использовать для этого обработчик, пожалуйста, проверьте мою новую тему stackoverflow.com/questions/51493431/ - person CKocar; 24.07.2018