Хорошо, я думаю, что знаю, что я сделал не так. Потоки объектов более сложны, кажется, что конструктору ObjectInputStream нужны данные для работы, прежде чем он создаст поток. Я решил эту проблему с помощью
- Создание ООС.
- Запустить конструктор для OIS в отдельном потоке.
- Запишите некоторые данные в OOS и очистите их.
- Подождите, пока OIS инициализируется, прежде чем читать с него.
Это то, что я сейчас использую (обратите внимание, что я также добавил буфер):
public ConnectedThread(BluetoothSocket socket,Handler h) {
mmSocket = socket;
mHandler = h;
InputStream tmpIn = null;
OutputStream tmpOut = null;
// Get the input and output streams, using temp objects because
// member streams are final
try {
tmpIn = socket.getInputStream();
tmpOut = socket.getOutputStream();
} catch (Exception e) {
Log.d(TAG,"Error in getting Input Streams");
Log.w(TAG,e);
}
mmInStream = tmpIn;
mmOutStream = tmpOut;
Log.d(TAG,"The socket is: " + mmSocket);
Log.d(TAG,"The streams are: " + mmInStream + mmOutStream);
Log.d(TAG,"attempting to create BufStreams");
final BufferedOutputStream bufo = new BufferedOutputStream(mmOutStream);
final BufferedInputStream bufi = new BufferedInputStream(mmInStream);
Log.d(TAG,"attempting to create OOS");
try {
oos = new ObjectOutputStream(bufo);
} catch (StreamCorruptedException e) {
Log.d(TAG,"Caught Corrupted Stream Exception");
Log.w(TAG,e);
} catch (IOException e) {
Log.d(TAG,"Caught IOException");
Log.w(TAG,e);
}
Log.d(TAG,"done OOS");
if(oos==null)
{
Log.d(TAG,"oos is null!!!!");
}
Thread s = new Thread(){
public void run(){
Log.d(TAG,"attempting to create OIS");
try {
ois = new ObjectInputStream(bufi);
} catch (StreamCorruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
Log.d(TAG,"completed OIS");
if(ois == null)
{
Log.d(TAG,"OIS is null");
}
}
};
s.start();
try {
Log.d(TAG,"writing and flushing 1");
oos.write(1);
oos.flush();
} catch (IOException e1) {
Log.d(TAG,"CaugtIOexception");
Log.w(TAG,e1);
}
Log.d(TAG,"sleeping to make sure stream is set up");
while (ois == null) {
try {
Thread.sleep(500);
} catch (InterruptedException e2) {
// TODO Auto-generated catch block
e2.printStackTrace();
}
}
Log.d(TAG, "done Sleeping");
// Read out the 1 to make sure everything is okay
int i = 0;
try {
i = ois.read();
} catch (IOException e) {
Log.d(TAG, "error reading");
e.printStackTrace();
}
Log.d(TAG,"I received an i of: " + i);
Log.d(TAG,"OO Streams set up");
}
public void run() {...