我在以下代码中遇到问题
def create
mythreads=[]
mythreads=Thread.list
@device_id=params[:data]['device_id']
if mythreads[@device_id].alive?
//I want this stuff
else
mythreads[@device_id]=Thread.new(arg) { savedata(params[:data]) }
end
end
def savedata(data)
Model.create(data)
end
数据是通过邮寄请求来的
如果未创建,我想为每个 device_id 创建单独的线程
如果它已经创建,我想使用同一个线程来存储数据
如果线程还活着,如果条件为真块,我应该写什么代码
将数据传递给现有线程???
以便调用 savedata() 函数并存储数据