求一个在鸿蒙ArkTS中加锁代码？

Question

求一个在鸿蒙ArkTS中加锁代码？

本文参与了 【 HarmonyOS NEXT 技术问答冲榜，等你来战！】欢迎正在阅读的你也加入。

Answer 1

ArkTS支持多种线程间数据的同步，但大部分情况下都是通过复制和传递，所以不存在锁的应用场景。 https://developer.huawei.com/consumer/cn/doc/harmonyos-guides...
唯一的一个例外是“可共享对象”-SharedArrayBuffer，可以通过原子操作实现同步。一个例子如下：

// index.ets 
var sab = new SharedArrayBuffer(32); 
// int32 buffer view for sab 
var i32a = new Int32Array(sab); 
i32a[0]=0; 
 
let producer = new worker.ThreadWorker("entry/ets/workers/worker_producer.ts") 
producer.postMessage(sab); 
let consumer = new worker.ThreadWorker("entry/ets/workers/worker_consumer.ts") 
consumer.postMessage(sab); 
 
 
// worker_producer.ts 
workerPort.onmessage = function(e : MessageEvents) { 
  var sab = e.data; 
  // view sab buffer in int32 array 
  var i32a = new Int32Array(sab); 
  console.info("Producer: received sab"); 
  // wake customer every 2s. 
  setInterval(function() { 
    var length = i32a.length; 
    for (var i = 1; i < length; i++) { 
      i32a[i] = Math.random() * length; 
    }; 
    Atomics.notify(i32a,0,1); // notify customer 
  },2000); 
} 
 
 
// worker_consumer.ts 
workerPort.onmessage = function(e : MessageEvents) { 
  var sab = e.data; 
  var i32a = new Int32Array(sab); 
  console.info("Customer: received sab"); 
  while(true) { 
    Atomics.wait(i32a,0,0);   //blocked here until be waked. 
    var length = i32a.length; 
    for (var i = length-1; i > 0; i--) { 
      console.info("arraybuffer " + i + " value is " + i32a[i]); 
      i32a[i] = i; 
    } 
  } 
}

本文参与了 【 HarmonyOS NEXT 技术问答冲榜，等你来战！】欢迎正在阅读的你也加入。