该数据集由一包文件组成，每个文件跟踪某些行业的正规化投入成本。
Producer Price Index_datasets.txt
pc.txt
pc.data.75.Construction.csv
pc.data.67.AdministrativeandSupportServ.csv
pc.series.csv
pc.product.csv
pc.period.csv
pc.industry.csv
pc.footnote.csv
pc.data.81.OtherServices.csv
pc.data.77.Recreation.csv
pc.data.76.WholesaleTrade.csv
pc.data.74.PremiumsforPropandCasualtyIns.csv
pc.data.73.MiscellaneousStoreRetailers.csv
pc.data.72.RecyclableMaterials.csv
pc.data.71.Accommodation.csv
pc.data.70.WasteMgtandRemediationServ.csv
pc.data.63.ProfessionalandTechnicalServ.csv
pc.data.62.RentalandLeasingServices.csv
pc.data.61.EducationalServices.csv
pc.data.59.RealEstate.csv
pc.data.58.InsuranceCarriers.csv
pc.data.57.Finance.csv
pc.data.56.ISPsSearchPortandDataProcess.csv
pc.data.55.Telecommunications.csv
pc.data.54.Broadcasting.csv
pc.data.53.Publishing.csv
pc.data.51.NursingResidentialCareFacil.csv
pc.data.50.Hospitals.csv
pc.data.47.AmbulatoryHealthCareServices.csv
pc.data.46.Utilities.csv
pc.data.45.WarehousingStorage.csv
pc.data.44.CouriersAndMessengers.csv
pc.data.43.PostalService.csv
pc.data.42.TransportationSupport.csv
pc.data.40.PipelineTransportation.csv
pc.data.39.TruckTransportation.csv
pc.data.38.WaterTransportation.csv
pc.data.37.RailTransportation.csv
pc.data.36.AirTransportation.csv
pc.data.35.NonstoreRetailers.csv
pc.data.34.GeneralStores.csv
pc.data.33.SportsMusicStores.csv
pc.data.32.ClothingStores.csv
pc.data.31.GasolineStations.csv
pc.data.30.HealthStores.csv
pc.data.29.FoodBeverageStores.csv
pc.data.28.BuildingGardenStores.csv
pc.data.27.ElectronicsStores.csv
pc.data.26.FurnitureStores.csv
pc.data.25.MotorVehicleDealers.csv
pc.data.24.Miscellaneous.csv
pc.data.23.Furniture.csv
pc.data.22.TransportationEquipment.csv
pc.data.21.ElectricalMachinery.csv
pc.data.20.ComputerProduct.csv
pc.data.19.Machinery.csv
pc.data.18.FabricatedMetalProduct.csv
pc.data.17.PrimaryMetal.csv
pc.data.16.NonmetallicMineral.csv
pc.data.15.PlasticsR
2022-03-01 12:38:45
16.31MB
1
调试kafka，一个生产者（通过postman调用可生产数据），一个消费者（自动消费）
2022-02-23 19:03:17
106KB
1
Kafka 生产者和消费者实现源码
下载前你可以先看一下我的博文
https://blog.csdn.net/xy596356456/article/details/121910260
你也可以按照我的文章一步步实现
2022-02-17 19:10:40
115KB
1
springboot整合dubbo，通过maven分模块实现基础接口、生产者、消费者，连接本地安装的zookeeper实现负载均衡
2022-02-11 10:33:40
51KB
1
该程序实现了在UCOS下对内存的管理，包括建立一个内存分区OSMemCreate（），分配一个内存块OSMemGet（），释放一个内存块OSMemPut（），查询一个内存分区的状态OSMemQuery（）。
该程序建立了两个内存分区，每个分区分了4个块，每个分区4个字节，为了区分每个分区不同的状态，设立一个随机数RandomSem。
每个分区有5个任务，随机调用每个分区里的4个内存块。
在TaskStart里建立两个分区，在Task里完成分配和释放内存块的任务。
OSMemQuery提供了查询内存块的总数，空闲的内存块，内存块的大小，使用的内存块，指向空闲内存块链表首地址的指针。
2022-01-01 00:55:45
10KB
1
实验内容：
① 由用户指定要产生的进程及其类别，存入进入就绪队列。
② 调度程序从就绪队列中提取一个就绪进程运行。如果申请的资源被阻塞则进入相应的等待队列，调度程序调度就绪队列中的下一个进程。进程运行结束时，会检查对应的等待队列，激活队列中的进程进入就绪队列。运行结束的进程进入over链表。重复这一过程直至就绪队列为空。
③ 程序询问是否要继续？如果要转直①开始执行，否则退出程序。
实验目的：
通过实验模拟生产者与消费者之间的关系，了解并掌握他们之间的关系及其原理。由此增加对进程同步的问题的了解。
实验要求：
每个进程有一个进程控制块（PCB）表示。进程控制块可以包含如下信息：进程
2021-12-30 22:01:52
4KB
1
package producer;
import java.util.Vector;//输入java矢量
class SyncStack
{//实现堆栈功能，不能同时读写
private Vector buffer//私人接口向量缓冲区
= new Vector
//新建向量
(400,200);
char contents;
private boolean ava=false;
public synchronized char get()
{//出栈
while (ava==false) //如果生产者还没有产生字符就一直等待
{
try
{
this.wait();
}
catch (InterruptedException e)//当线程在活动之前或活动期间处于正在等待、休眠或占用状态且该线程被中断时，抛出该异常
{
e. printStackTrace();
}
}
ava=false;
notifyAll();
return contents;
}
public synchronized void push(char c)
{
while(ava==true){
try {
wait();
} catch (InterruptedException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
}
}//入栈
ava=true;
this.notify();//通知其它线程把数据出栈
Character charObj = new Character(c);
buffer.addElement(charObj);
contents=c;
}
public void print(char c) {
// TODO 自动生成方法存根
}
}
class ControlEnter
{//每行输出结果的个数
public static int count = 0;
void counter()
{
count++;
if(count ==5)
{
System.out.println();
count = 0;
}
}
}
class Producer implements Runnable
{//生产者类
private SyncStack theStack;//生产者类获得的字符都来自同步堆栈
private ControlEnter controlenter;
public Producer (SyncStack s,ControlEnter ce)
{
theStack = s;
controlenter = ce;
}
public void run()
{
char c;
for (int i = 0; i < 30; i++)
{
c = (char)(Math.random() * 26 + 'a');//随机产生30个小写字母
theStack.push(c);//存入堆栈
System.out.print("生产者产生: " + c +" ");
controlenter.counter( );
try
{
Thread.sleep//线程休眠
((int)(Math.random() * 200));//以0~200ms的速度随机
}
catch (InterruptedException e) //当线程在活动之前或活动期间处于正在等待、休眠或占用状态且该线程被中断时，抛出该异常
{
e.printStackTrace( );
}
}
}
}
class Consumer implements Runnable
{//消费者类
private SyncStack theStack;//消费者类获得的字符都来自同步堆栈
private ControlEnter controlenter;
public Consumer (SyncStack s,ControlEnter ce)
{
theStack = s;
controlenter = ce;
}
public void run()
{
char value;
for (int i=0; i < 30; i++) {//从堆栈中取数，并输出
value = theStack.get();//取出生产者产生的字母
System.out.print("消费者消费: " + value+" ");//消费者输出
controlenter.counter( );
try {
Thread.sleep((int)
(Math.random() * 2000));//控制取数的速度：0～2s/*每读取一个字符线程就睡眠*/
} catch (InterruptedException e)//当线程在活动之前或活动期间处于正在等待、休眠或占用状态且该线程被中断时，抛出该异常
{
e.printStackTrace();
}
}
}
}
public class B {//主线程总调度
public static void main(String []args)
{
ControlEnter ce = new ControlEnter();
SyncStack stack = new SyncStack();//下面的消费者类对象和生产者类对象所操作的是同一个同步堆栈对象
Producer p1 = new Producer(stack,ce);
new Thread(p1).start();//生产者线程启动
Consumer c1 = new Consumer(stack,ce);
new Thread(c1).start();//消费者线程启动
}
}
2021-12-25 16:14:49
3KB
1