for i in range(n): if i % (n//10) == 0: print("%0.1f"%(i/n))#每当完成总任务的10%输出 if i> 0 and i % Delta == 0: # 索引从零开始计数 if Delta > 1: max_k = max(np.array(k_idx_his[-Delta:-1])%K) +1 else: max_k = k_idx_his[-1] +1 K = min(max_k +1, N)#根据历史记录动态调整K的值,以使其能够适应数据流的变化。如果数据流的变化比较平稳,则K的值不会经常变化,这样可以避免频繁的参数更新。如果数据流的变化比较剧烈,则K的值会相应地进行调整,以更好地适应新的数据分布 i_idx = i # 实时信道生成 h_tmp = racian_mec(h0,0.3)#使用Rician衰落模型后的增益值 # 将h0增长到1,以便更好的训练; 这是深度学习中广泛采用的一种技巧 h = h_tmp*CHFACT channel[i,:] = h #变量h_tmp乘以常数CHFACT,然后将结果存储到变量h中。接着,将h赋值给二维数组channel的第i行,获取信道增益值 # 实时到达生成 dataA[i,:] = np.random.exponential(arrival_lambda) # 4) LyDROO的排队模型 if i_idx > 0: # 更新队列 Q[i_idx,:] = Q[i_idx-1,:] + dataA[i_idx-1,:] - rate[i_idx-1,:] # 当前队列 # 由于浮点错误,断言Q是正的 Q[i_idx,Q[i_idx,:]<0] =0 Y[i_idx,:] = np.maximum(Y[i_idx-1,:] + (energy[i_idx-1,:]- energy_thresh)*nu,0) # 当前能量队列 # 由于浮点错误,断言Y是正的 Y[i_idx,Y[i_idx,:]<0] =0#防止浮点错误 # 缩放Q和Y到接近1;深度学习技巧 nn_input =np.concatenate( (h, Q[i_idx,:]/10000,Y[i_idx,:]/10000)) # Actor module m_list = mem.decode(nn_input, K, decoder_mode) r_list = [] # 所有候选卸载模式的结果 v_list = [] # 候选卸载模式的目标值 for m in m_list: # Critic module # 为保存在m_list中的所有生成的卸载模式分配资源 r_list.append(Algo1_NUM(m,h,w,Q[i_idx,:],Y[i_idx,:],V)) v_list.append(r_list[-1][0]) # 记录最大奖励指数 k_idx_his.append(np.argmax(v_list)) # Policy update module # 编码最大奖励模式 mem.encode(nn_input, m_list[k_idx_his[-1]]) mode_his.append(m_list[k_idx_his[-1]])#将m_list最后一条历史消息添加到历史消息列表中。,在这个算法中取消对队列积压的考虑
时间: 2023-12-06 15:41:32 浏览: 21
这段代码是一个 LyDROO 协议的实现,其中包括了信道生成、实时到达生成、队列模型、Actor 模块、Critic 模块和 Policy update 模块。LyDROO 是一种用于无线网络中能量有限的设备卸载计算任务的协议。这段代码主要是实现了 LyDROO 协议中的 Actor-Critic 算法,用于对卸载模式进行决策,并且根据卸载模式的奖励值来更新策略。同时,为了适应数据流的变化,K 的值会根据历史记录动态调整,以更好地适应新的数据分布。
相关问题
Q = np.zeros((n,N)) # MbitsW数据队列矩阵 Y = np.zeros((n,N)) # mJ的虚拟能量队列,用于存储初始化为零的二维数值数据 Obj = np.zeros(n) # 在解决问题26之后的目标值,初始化为零 energy = np.zeros((n,N)) # 能源消耗数组矩阵 rate = np.zeros((n,N)) # 实现的计算速率 for i in range(n): if i % (n//10) == 0: print("%0.1f"%(i/n))#每当完成总任务的10%输出 if i> 0 and i % Delta == 0: # 索引从零开始计数 if Delta > 1: max_k = max(np.array(k_idx_his[-Delta:-1])%K) +1 else: max_k = k_idx_his[-1] +1 K = min(max_k +1, N)#根据历史记录动态调整K的值,以使其能够适应数据流的变化。如果数据流的变化比较平稳,则K的值不会经常变化,这样可以避免频繁的参数更新。如果数据流的变化比较剧烈,则K的值会相应地进行调整,以更好地适应新的数据分布 i_idx = i # 实时信道生成 h_tmp = racian_mec(h0,0.3)#使用Rician衰落模型后的增益值 # 将h0增长到1,以便更好的训练; 这是深度学习中广泛采用的一种技巧 h = h_tmp*CHFACT channel[i,:] = h #变量h_tmp乘以常数CHFACT,然后将结果存储到变量h中。接着,将h赋值给二维数组channel的第i行,获取信道增益值 # 实时到达生成 dataA[i,:] = np.random.exponential(arrival_lambda) # 4) LyDROO的排队模型 if i_idx > 0: # 更新队列 Q[i_idx,:] = Q[i_idx-1,:] + dataA[i_idx-1,:] - rate[i_idx-1,:] # 当前队列 # 由于浮点错误,断言Q是正的 Q[i_idx,Q[i_idx,:]<0] =0 Y[i_idx,:] = np.maximum(Y[i_idx-1,:] + (energy[i_idx-1,:]- energy_thresh)*nu,0) # 当前能量队列 # 由于浮点错误,断言Y是正的 Y[i_idx,Y[i_idx,:]<0] =0#防止浮点错误 # 缩放Q和Y到接近1;深度学习技巧 nn_input =np.concatenate( (h, Q[i_idx,:]/10000,Y[i_idx,:]/10000)) # Actor module m_list = mem.decode(nn_input, K, decoder_mode),修改算法使算法不考虑队伍积压问题
这段代码看起来是一个LyDROO算法的实现。LyDROO是一种用于优化无线网络中资源分配的算法,它基于强化学习和排队论。在这段代码中,Q和Y分别表示数据队列和虚拟能量队列,Obj表示目标值,energy表示能源消耗数组矩阵,rate表示实现的计算速率。算法通过调整K的值来适应数据流的变化,同时使用Rician衰落模型计算信道增益值。在排队模型方面,算法更新队列和能量队列,并将它们缩放到接近1的范围内作为Actor模块的输入。最后,算法使用mem.decode函数对输入进行解码,得到m_list列表,该列表包含了算法在当前状态下可能采取的动作。值得注意的是,这段代码中取消了队伍积压问题的考虑。
X2=[] X3=[] X4=[] X5=[] X6=[] X7=[] X1=[i for i in range(1,24) for j in range(128)] X1=X1[:2928] df=pd.read_excel('C:/Users/86147/OneDrive/文档/777.xlsx',header=0,usecols=(3,)) X2=df.values.tolist() x2=[] x21=[] for i in X2: if X2.index(i)<=2927: x2.append(i) else: x21.append(i) # x2=x2[:len(x21)] df=pd.read_excel('C:/Users/86147/OneDrive/文档/777.xlsx',header=0,usecols=(4,)) X3=df.values.tolist() x3=[] x31=[] for i in X3: if X3.index(i)<=2927: x3.append(i) else: x31.append(i) # x3=x3[:len(x31)] df=pd.read_excel('C:/Users/86147/OneDrive/文档/777.xlsx',header=0,usecols=(5,)) X4=df.values.tolist() x4=[] x41=[] for i in X4: if X4.index(i)<=2927: x4.append(i) else: x41.append(i) # x4=x4[:len(x41)] df=pd.read_excel('C:/Users/86147/OneDrive/文档/777.xlsx',header=0,usecols=(6,)) X5=df.values.tolist() x5=[] x51=[] for i in X5: if X5.index(i)<=2927: x5.append(i) else: x51.append(i) # x5=x5[:len(x51)] df=pd.read_excel('C:/Users/86147/OneDrive/文档/777.xlsx',header=0,usecols=(7,)) X6=df.values.tolist() x6=[] x61=[] for i in X6: if X6.index(i)<=2927: x6.append(i) else: x61.append(i) # x6=x6[:len(x61)] df=pd.read_excel('C:/Users/86147/OneDrive/文档/777.xlsx',header=0,usecols=(8,)) X7=df.values.tolist() x7=[] x71=[] for i in X7: if X7.index(i)<=2927: x7.append(i) else: x71.append(i) # x7=x7[:len(x71)]np.random.seed(42) q=np.array(X1) w=np.array(x2) e=np.array(x3) r=np.array(x4) t=np.array(x5) p=np.array(x6) u=np.array(x7) eps=np.random.normal(0,0.05,152) X=np.c_[q,w,e,r,t,p,u] beta=[0.1,0.15,0.2,0.5,0.33,0.45,0.6] y=np.dot(X,beta) X_model=sm.add_constant(X) model=sm.OLS(y,X_model) results=model.fit() print(results.summary())具体代码如下,要怎么修改?
根据你的代码,报错是由于有些数组在第0维上的大小不匹配,导致无法使用`np.c_`函数进行连接。具体来说,`x2`、`x3`、`x4`、`x5`、`x6`、`x7`这些数组在第0维上的大小都是5808,而`X1`数组在第0维上的大小是2928,因此它们无法在列方向上进行连接。
为了解决这个问题,你需要将`X1`数组的大小调整为5808,可以使用`np.repeat`函数将`X1`中的每个元素重复2次,以便与其他数组在第0维上的大小相匹配。修改后的代码如下所示:
```
import numpy as np
import pandas as pd
import statsmodels.api as sm
X1 = np.repeat(np.arange(1, 24), 256) # 将2928个元素重复2次,形成大小为5808的数组
df = pd.read_excel('C:/Users/86147/OneDrive/文档/777.xlsx', header=0, usecols=[3, 4, 5, 6, 7, 8])
X2, X3, X4, X5, X6, X7 = [df.values[:, i] for i in range(6)]
np.random.seed(42)
q, w, e, r, t, p, u = X1, X2, X3, X4, X5, X6, X7
eps = np.random.normal(0, 0.05, 152)
X = np.c_[q, w, e, r, t, p, u]
beta = [0.1, 0.15, 0.2, 0.5, 0.33, 0.45, 0.6]
y = np.dot(X, beta)
X_model = sm.add_constant(X)
model = sm.OLS(y, X_model)
results = model.fit()
print(results.summary())
```
修改后的代码中,我使用了`np.repeat`函数将`X1`中的每个元素重复2次,形成了大小为5808的数组。然后,我将`X2`到`X7`的读取操作简化为了一行代码,使用了一个列表推导式和`df.values`属性来读取这些列。最后,我将所有变量传递给`np.c_`函数进行连接。
希望这个修改可以帮助你解决问题。
阅读全文