TaskRunner

คลาสสาธารณะ TaskRunner

ตัวเรียกใช้กราฟงาน MediaPipe

วิธีการสาธารณะ

void
close()
ปิดและล้างอินสแตนซ์ TaskRunner
TaskRunner แบบคงที่
create(บริบทบริบท, TaskInfo<? ขยาย TaskOptions>taskInfo, OutputHandler<? ขยาย TaskResult, ?> exportHandler)
สร้างอินสแตนซ์ TaskRunner
CalculatorGraphConfig
getCalculatorGraphConfig()
AndroidPacketCreator
getPacketCreator()
แสดงผล ERROR(/AndroidPacketCreator) ที่เชื่อมโยงกับอินสแตนซ์ TaskRunner
ซิงค์ข้อมูลแล้ว TaskResult
กระบวนการ(อินพุตแมป<สตริง, Packet>)
วิธีการแบบซิงโครนัสสำหรับการประมวลผลข้อมูลแบบกลุ่ม
ซิงค์ข้อมูลแล้ว TaskResult
Process(อินพุต Map<String, Packet>, Long InputTimestamp)
วิธีการแบบซิงโครนัสในการประมวลผลข้อมูลสตรีมมิงออฟไลน์
void
รีสตาร์ท()
รีเซ็ตและรีสตาร์ทอินสแตนซ์ TaskRunner
ทำให้ข้อมูลตรงกัน เป็นโมฆะ
send(อินพุต Map<String, Packet>, Long InputTimestamp)
วิธีแบบไม่พร้อมกันสำหรับการจัดการข้อมูลสตรีมมิงแบบสด
void
setErrorListener(Listener ErrorListener)
ตั้งค่าการเรียกใช้โค้ดเรียกกลับเมื่ออินสแตนซ์ TaskRunner พบข้อยกเว้น

วิธีการที่รับช่วงมา

วิธีการสาธารณะ

สาธารณะ โมฆะ ปิด ()

ปิดและล้างอินสแตนซ์ TaskRunner

Public static TaskRunner create (บริบทบริบท, TaskInfo<? ขยาย TaskOptions>taskInfo, OutputHandler<? ขยายเอาต์พุต TaskResult, ?>

สร้างอินสแตนซ์ TaskRunner

พารามิเตอร์
บริบท Android ERROR(/Context)
taskInfo อินสแตนซ์ TaskInfo มีชื่อกราฟงาน ตัวเลือกงาน รวมถึงชื่อสตรีมอินพุตและเอาต์พุตกราฟ
outputHandler อินสแตนซ์ OutputHandler จะจัดการออบเจ็กต์ผลลัพธ์ของงานและข้อยกเว้นรันไทม์
การขว้าง
เพื่อหาข้อผิดพลาดระหว่างการสร้าง TaskRunner

สาธารณะ CalculatorGraphConfig getCalculatorGraphConfig ()

สาธารณะ AndroidPacketCreator getPacketCreator ()

แสดงผล ERROR(/AndroidPacketCreator) ที่เชื่อมโยงกับอินสแตนซ์ TaskRunner

สาธารณะ ซิงค์ TaskResult การประมวลผล (อินพุตของ<สตริง, Packet>)

วิธีการแบบซิงโครนัสสำหรับการประมวลผลข้อมูลแบบกลุ่ม

หมายเหตุ: วิธีนี้ออกแบบมาสำหรับการประมวลผลข้อมูลแบบกลุ่ม เช่น รูปภาพและข้อความที่ไม่เกี่ยวข้อง การเรียกใช้จะบล็อกเทรดปัจจุบันจนกว่าจะแสดงสถานะไม่สำเร็จหรือได้ผลลัพธ์สำเร็จ ระบบจะกำหนดการประทับเวลาภายในตามการเรียกใช้ เมธอดนี้ปลอดภัยสำหรับชุดข้อความและอนุญาตให้ไคลเอ็นต์เรียกใช้จากเทรดที่ต่างกัน

พารามิเตอร์
อินพุต แผนที่มีคู่ (สตรีมอินพุต String, ข้อมูล ERROR(/Packet))

สาธารณะ ซิงค์ TaskResult กระบวนการ (แมป<สตริง, อินพุต Packet>, Long InputTimestamp)

วิธีการแบบซิงโครนัสในการประมวลผลข้อมูลสตรีมมิงออฟไลน์

หมายเหตุ: วิธีนี้ออกแบบมาเพื่อประมวลผลข้อมูลสตรีมมิงออฟไลน์ เช่น เฟรมที่ถอดรหัสจากไฟล์วิดีโอและไฟล์เสียง การเรียกใช้จะบล็อกเทรดปัจจุบันจนกว่าจะมีการแสดงสถานะล้มเหลวหรือแสดงผลลัพธ์สำเร็จ ผู้เรียกใช้ต้องตรวจสอบว่าการประทับเวลาอินพุตมากกว่าการประทับเวลาของการเรียกใช้ก่อนหน้า วิธีการนี้ไม่ปลอดภัยและเทรดเป็นความรับผิดชอบของผู้โทรในการซิงค์การเข้าถึงเมธอดนี้ในหลายๆ เทรด รวมถึงตรวจสอบว่าการประทับเวลาของแพ็กเก็ตอินพุตอยู่ในลำดับที่ถูกต้อง

พารามิเตอร์
อินพุต แผนที่มีคู่ (สตรีมอินพุต String, ข้อมูล ERROR(/Packet))
inputTimestamp การประทับเวลาของแพ็กเก็ตอินพุต

สาธารณะ โมฆะ รีสตาร์ท ()

รีเซ็ตและรีสตาร์ทอินสแตนซ์ TaskRunner ซึ่งอาจมีประโยชน์ในการรีเซ็ตกราฟงานแบบเก็บสถานะเพื่อประมวลผลข้อมูลใหม่

สาธารณะ ซิงค์ข้อมูลแล้ว void ส่ง (แมป<สตริง, Packet>, อินพุต LongTimestamp)

วิธีแบบไม่พร้อมกันสำหรับการจัดการข้อมูลสตรีมมิงแบบสด

หมายเหตุ: วิธีการนี้ออกแบบมาเพื่อจัดการข้อมูลสตรีมมิงแบบสด เช่น ข้อมูลกล้องและไมโครโฟนแบบสด ต้องระบุฟังก์ชันการเรียกกลับแพ็กเก็ตที่ผู้ใช้กำหนดในเครื่องมือสร้างเพื่อรับแพ็กเก็ตเอาต์พุต ผู้เรียกใช้ต้องตรวจสอบว่าการประทับเวลาแพ็กเก็ตอินพุตเพิ่มขึ้นอย่างต่อเนื่อง เมธอดนี้ไม่ปลอดภัยเทรด และผู้โทรมีหน้าที่ซิงค์สิทธิ์เข้าถึงเมธอดนี้ในหลายเทรด รวมถึงตรวจสอบว่าการประทับเวลาของแพ็กเก็ตอินพุตอยู่ในลำดับที่ถูกต้อง

พารามิเตอร์
อินพุต แผนที่มีคู่ (สตรีมอินพุต String, ข้อมูล ERROR(/Packet))
inputTimestamp การประทับเวลาของแพ็กเก็ตอินพุต

สาธารณะ void setErrorListener (ErrorListener Listener)

ตั้งค่าการเรียกใช้โค้ดเรียกกลับเมื่ออินสแตนซ์ TaskRunner พบข้อยกเว้น

พารามิเตอร์
Listener การเรียกกลับผ่าน ErrorListener