質問編集履歴

スレッドを立てている部分のコードを追加しました。

2018/04/25 00:37

投稿

shikasama

スコア163

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -50,6 +50,478 @@
+**追記**
+画像データの取得(ソケット通信)でスレッドを立てています。
+参考になるかわかりませんが、いかにその部分を抜き出したコードを記載します。
+波形データ取得部分
+```kotlin
+private fun getScreenImage() {
+    isStop = false
+    isTriggerStoped = false
+    if(socketControl?.isConnect() == false) {
+        // 未接続
+        return
+    }
+    buttonSave.isEnabled = false
+    Toast.makeText(applicationContext, getString(R.string.text_image_acquisition_start), Toast.LENGTH_SHORT).show()
+    Thread(Runnable {
+        while(!isStop) {
+            Thread.sleep(0)
+            waitForTrgStop()
+            isTriggerStoped = false
+            receiveBuff = null
+            // 画像転送コマンド送信(受信データはBinary)
+            var str = "(画像転送コマンド)"
+            str += "PNG"
+            Thread.sleep(10)
+            socketControl?.sendCommand(str, true)
+            var timeout = 500
+            while (true) {
+                try {
+                    Thread.sleep(80)
+                    if(timeout < 0) {
+                        break
+                    } else if(receiveBuff != null) {
+                        imageData = receiveBuff?.copyOf()
+                        receiveBuff = null
+                        Thread.sleep(10)
+                        break
+                    }
+                } catch (e: Exception) {
+                    e.printStackTrace()
+                }
+                timeout -= 100
+            }
+            if(timeout < 0) {
+                continue
+            }
+            if(!checkBoxContinuousAcquisition.isChecked) {
+                isStop = true
+            }
+            class Mythread : Thread() {
+                override fun run() {
+                    var bmp : Bitmap? = null
+                    var imageSize = 0
+                    if(imageData != null) {
+                        imageSize = imageData?.size ?: 0
+                        bmp = BitmapFactory.decodeByteArray(imageData, 0, imageSize)
+                    }
+                    if(imageSize == 0) {
+                        Toast.makeText(applicationContext, getString(R.string.text_imageData_size_0), Toast.LENGTH_SHORT).show()
+                        return
+                    }
+                    if(bbmp == null) {
+                        Glide.with(applicationContext)
+                                .load(bmp)
+                                .into(imageViewWaveform)
+                        bbmp = bmp
+                    }
+                    else {
+                        requestOptions.placeholder(BitmapDrawable(resources,bmp))
+                        Glide.with(applicationContext)
+                                .load(bmp)
+                                .apply(requestOptions)
+                                .into(imageViewWaveform)
+                        bbmp = bmp
+                    }
+                    if(isTriggerStoped) {
+                        isTriggerStoped = false
+                    }
+                }
+            }
+            val myRun = Mythread()
+            runOnUiThread(myRun)
+            myRun.join()
+            Thread.sleep(1)
+        }
+        if(checkBoxContinuousAcquisition.isChecked) {
+            receiveBuff = null
+            // 画像転送コマンド送信(受信データはBinary)
+            var str = "(画像転送コマンド) "
+            str += "PNG"
+            Thread.sleep(100)
+            socketControl?.sendCommand(str, true)
+            while (true) {
+                try {
+                    Thread.sleep(100)
+                    if(receiveBuff != null) {
+                        imageData = receiveBuff?.copyOf()
+                        receiveBuff = null
+                        Thread.sleep(10)
+                        break
+                    }
+                } catch (e: Exception) {
+                    e.printStackTrace()
+                }
+            }
+            class Mythread2 : Thread() {
+                override fun run() {
+                    var bmp : Bitmap? = null
+                    var imageSize = 0
+                    if(imageData != null) {
+                        imageSize = imageData?.size ?: 0
+                        bmp = BitmapFactory.decodeByteArray(imageData, 0, imageSize)
+                    }
+                    if(imageSize == 0) {
+                        Toast.makeText(applicationContext, getString(R.string.text_imageData_size_0), Toast.LENGTH_SHORT).show()
+                        return
+                    }
+                    if(bbmp == null) {
+                        Glide.with(applicationContext)
+                                .load(bmp)
+                                .into(imageViewWaveform)
+                        bbmp = bmp
+                    }
+                    else {
+                        requestOptions.placeholder(BitmapDrawable(resources,bmp))
+                        Glide.with(applicationContext)
+                                .load(bmp)
+                                .apply(requestOptions)
+                                .into(imageViewWaveform)
+                        bbmp = bmp
+                    }
+                    if(isTriggerStoped) {
+                        isTriggerStoped = false
+                    }
+                }
+            }
+            val myRun2 = Mythread2()
+            runOnUiThread(myRun2)
+            myRun2.join()
+        }
+        class Mythread3 : Thread() {
+            override fun run() {
+                buttonGetScreenImage.isEnabled = true
+                buttonSave.isEnabled = true
+                Toast.makeText(applicationContext, getString(R.string.text_image_acquisition_stop), Toast.LENGTH_SHORT).show()
+            }
+        }
+        val myRun3 = Mythread3()
+        runOnUiThread(myRun3)
+        myRun3.join()
+    }).start()
+}
+```
+ソケット通信でのデータ送信部分
+```kotlin
+fun sendCommand(sendStr: String, isBinaryReceive: Boolean): Boolean {
+    if (this.socketClient?.isConnect() != true) {
+        // 未接続
+        return false
+    }
+    this.isBinary = isBinaryReceive
+    this.receiveBuff = null
+    this.receiveNum = 0
+    val str = sendStr + "\r\n"
+    val data = str.toByteArray(Charsets.UTF_8)
+    this.socketClient?.sendThread(data)
+    return true
+}
+fun sendThread(data : ByteArray) : Boolean {
+    var result = false
+    this.sendBuff = data
+    try {
+        thread {
+            result = send(sendBuff)
+        }.join()
+    }
+    catch (e : Exception) {
+        Log.d("TCP/IP sendTh", e.toString())
+    }
+    return result
+}
+private fun send(data : ByteArray) : Boolean {
+    var result = false
+    try {
+        output?.write(data, 0, data.size)
+        output?.flush()
+        result = true
+    } catch (e : Exception) {
+        Log.e("TCP/IP send", e.toString())
+        return result
+    }
+    return result
+}
+```
 ### 補足情報（FW/ツールのバージョンなど）