public void Get() { new Thread(new Runnable() { @Override public void run() { try { //接受温度 API_KEY_SET(); OkHttpClient client = new OkHttpClient(); Request request = new Request.Builder().url("http://api.heclouds.com/devices/" + DeviceID + "/datapoints?datastream_id=" + key1).header("api-key", ApiKey).build(); Response response = client.newCall(request).execute(); String responseData = response.body().string(); parseJSONWithGSON(responseData);

public void serach(final String serachinput) { if (serachinput.equals("") || serachinput == null) { load(); } else { new Thread(new Runnable() { @Override public void run() { try { String url = "/computer/serach?componname=" + serachinput; Call call = okhttputil.request_get(url); Response execute = call.execute(); String string = execute.body().string(); JSONObject jsonObject = new JSONObject(string); data = jsonObject.getString("data"); handler.post(udpUIRunnable); } catch (Exception e) { e.printStackTrace(); } } }).start(); }

它接受一个搜索输入（serachinput），如果输入为空或者为null，则加载一些默认的数据（load()方法）。否则，它会在一个新线程中进行搜索，并将结果存储在一个名为"data"的变量中。接着，它会使用一个Handler来更新UI...

public void load(final int state){ new Thread(new Runnable() { @Override public void run() { String url = "/order/display/state?username=\'"+ MainActivity.loginusername+"\'&state="+state; Call call = okhttputil.request_get(url); try{ String string = call.execute().body().string(); JSONObject jsonObject = new JSONObject(string); data = jsonObject.getString("data"); handler.post(udpUIRunnable); }catch (Exception e){ e.printStackTrace(); } } }).start(); }

这段代码定义了一个 load 方法，它接受一个 int 类型的参数 state。这个方法会在一个新线程中执行，它首先构造一个 URL 字符串，然后使用 OkHttp 库发送一个 GET 请求，并将响应结果存储到一个字符串中。接着，它将...

优化代码运用线程知识package D18; public class D18_1 { public static void main(String[] args) { // TODO Auto-generated method stub } } class Account implements Runnable{ private int money; //修改方法 //存钱 public void deposit(int amount) { money +=amount; System.out.println("存钱成功，现有"+money); } @Override public void run() { // TODO Auto-generated method stub deposit(100); } public int getMoney() { return money; } public void setMoney(int money) { this.money = money; } }

public static void main(String[] args) throws InterruptedException { Account account = new Account(); Thread depositThread = new Thread(() -> { for (int i = 0; i ; i++) { account.deposit(100); }...

load(); exit.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { Intent intent = new Intent(); //前一个（MainActivity.this）是目前页面，后面一个是要跳转的下一个页面 intent.setClass(mContext, MainActivity.class); startActivity(intent); } }); return root; } public void load(){ new Thread(new Runnable() { @Override public void run() { try{ String url = "/user/selectone"; String string = okhttputil.request_get(url).execute().body().string(); JSONObject jsonObject = new JSONObject(string); data = jsonObject.getString("data"); handler.post(udpUIRunnable); }catch (Exception e){ e.printStackTrace(); } } }).start(); } Runnable udpUIRunnable = new Runnable() { @Override public void run() { user user = JSON.parseObject(data, user.class); username.setText("用户名："+user.getUsername()); nickname.setText("昵称："+user.getNickname()); tel.setText("电话："+user.getTel()); emile.setText("邮箱："+user.getEmile()); address.setText("地址："+user.getAddress()); } }; }

load 方法是在子线程中发送一个 GET 请求获取服务器返回的用户数据，然后通过 handler.post 方法将得到的数据传递给 udpUIRunnable 对象中的 run 方法。udpUIRunnable 对象中的 run 方法将用户数据解析为一个 user ...

public View getView(int position, View convertView, final ViewGroup parent) { Holder holder = null; if (convertView == null){ convertView = layoutInflater.inflate(R.layout.componlist_item,null); holder = new Holder(); holder.componname = convertView.findViewById(R.id.All_Compon_list_item_componname); holder.componbrand = convertView.findViewById(R.id.All_Compon_list_item_componbrand); holder.componprice = convertView.findViewById(R.id.All_Compon_list_item_componprice); holder.buycompon = convertView.findViewById(R.id.All_Compon_list_item_buy); convertView.setTag(holder); }else { holder = (Holder) convertView.getTag(); } componBean componBean = arrpayinf.get(position); holder.componname.setText(componBean.getComponname()); holder.componbrand.setText(componBean.getBrand()); holder.componprice.setText("价格:"+componBean.getPrice().toString()); final View finalConvertView = convertView; final Holder finalHolder = holder; holder.buycompon.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { String componname = finalHolder.componname.getText().toString(); String username = MainActivity.loginusername; FormBody.Builder parms = new FormBody.Builder(); parms.add("username",username); parms.add("componname",componname); final Call call = okhttputil.request_post("/order/buycompon", parms); new Thread(new Runnable() { @Override public void run() { try { String string = call.execute().body().string(); JSONObject jsonObject = new JSONObject(string); mark = jsonObject.getString("code").equals("200"); handler.post(udpUIRunnable); }catch (Exception e){ e.printStackTrace(); } } }).start(); } }); return convertView;

这是一个 Android 中的 ListView 的 Adapter 的 getView 方法的实现，用于展示一个组件列表中的每一个组件的信息。具体来说，对于每一个组件，该方法从组件列表中获取对应位置的组件信息，然后使用 Holder 类来存储...

package com.zte.ums.cnms.pm.datfileupload.ranomm.clean; import com.zte.ums.cnms.pm.datfileupload.ranomm.util.Utils; import lombok.extern.slf4j.Slf4j; import javax.inject.Inject; import java.util.HashMap; import java.util.Map; import java.util.List; import java.nio.file.Paths; @Slf4j public class FileCleanRunnable implements Runnable{ // @Inject // private FileCleanTask fileCleanTask; // @Inject // private CleanTaskPollService cleanTaskPollService; private FileCleanParaQueryService fileCleanParaQueryService=new FileCleanParaQueryService(); // private FileCleanTaskResponse fileCleanTaskResponse; private Map<String, Integer> cleanPathRetainMap=new HashMap<>(); private String dir; public FileCleanRunnable(String dir){ this.dir = dir; } @Override public void run() { //do cleaning // neIdDirs=fileCleanTask.getCleanDirs(); // log.info("prepared Clean Dir:"+dir); try { cleanDir(); } catch (Exception e) { log.error("File clean me dir: failed",e); } } private void cleanDir() { long startTimeMills = System.currentTimeMillis(); String tmpPath; log.info("fileCleanParaQueryService:"+fileCleanParaQueryService); Map<String, Integer> pmParas= fileCleanParaQueryService.getCleanParas(); cleanPathRetainMap.put(CleanUtil.FTP, pmParas.get(FileCleanParaQueryService.LOCAL_FTP)); cleanPathRetainMap.put(CleanUtil.BAK, pmParas.get(FileCleanParaQueryService.LOCAL_BAK)); cleanPathRetainMap.put(CleanUtil.PARSE_ERR, pmParas.get(FileCleanParaQueryService.LOCAL_PARSE_ERR)); log.info("File clean thread start, clean dir : {} ", dir); // for (String neIdDir : dir) { for (Map.Entry<String, Integer> entry : cleanPathRetainMap.entrySet()) { tmpPath = Paths.get(dir, entry.getKey()).toString(); log.info("tmpPath:"+tmpPath); Utils.deleleFilesOfDir(tmpPath, entry.getValue()); } // } log.info("File clean thread finish,dir size: {},cost: {} ms", dir, (System.currentTimeMillis() - startTimeMills)); } }写单元测试,框架为junit3

public void setUp() { fileCleanRunnable = new FileCleanRunnable(dir); } public void testCleanDir() { fileCleanRunnable.run(); // 在这里编写断言，验证代码的正确性 // ... } } 在上面的示例...

优化下面代码package Zzz; import java.awt.TexturePaint; import java.io.File; import java.io.FilenameFilter; import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.text.BreakIterator; import java.util.Scanner; import javax.imageio.metadata.IIOInvalidTreeException; import javax.imageio.plugins.jpeg.JPEGImageWriteParam; import javax.sound.sampled.Port; import org.omg.CORBA.INTERNAL; public class Test3{ public static void main(String[] args) throws IOException { // TODO Auto-generated method stub Scanner scanner=new Scanner(System.in); System.out.print("请输入对方的IP地址"); String ipAddress=scanner.nextLine(); InetAddress ip=InetAddress.getByName(ipAddress); System.out.print("请输入对方的端口号"); int toPort=scanner.nextInt(); System.out.print("请输入本地接受的端口号:"); int listenPort=scanner.nextInt(); new Thread(); new Thread(); } } class SendThread implements Runnable{ private int Port; private InetAddress ip; public SendThread(int Port,InetAddress ip) { this.ip=ip; this.Port=Port; // TODO Auto-generated constructor stub } @Override public void run() { // TODO Auto-generated method stub try { Scanner scanner=new Scanner(System.in); DatagramSocket socket=new DatagramSocket(); System.out.println("开始聊天"); DatagramPacket packet=new DatagramPacket(new byte[1024], 1024, ip, Port); while(true){ String zyk=scanner.nextLine(); packet.setData(zyk.getBytes()); socket.send(packet); if (zyk.equals("bye")) { break; } } System.out.println("退出聊天"); socket.close(); } catch (Exception e) { // TODO: handle exception } } } class RecieveThread implements Runnable{ private int Port; public RecieveThread(int Port){ this.Port=Port; } @Override public void run() { while(true){ try { DatagramSocket socket=n

public void run() { try { Scanner scanner = new Scanner(System.in); System.out.println("开始聊天"); while (true) { String message = scanner.nextLine(); DatagramPacket packet = new ...

将下列Java代码改为python代码：import java.util.ArrayList; import java.util.Comparator; import java.util.List; import java.util.concurrent.CountDownLatch; import java.net.; public class Scanport { public static void main(String[] args) throws InterruptedException { String host = "120.46.209.149"; int startPort = 1; int endPort = 1024; int start = 0; int end = 0; int step = Math.round(endPort / 1000) + 1;// 四舍五入函数 for (int i = 1; i < step; i++) { start = startPort + (i - 1) 1000; end = startPort + i * 1000; System.out.println("正在扫描" + start + "-" + end); scan(host, start, end); } } public static void scan(String host, int startPort, int endPort) throws InterruptedException { List<Integer> portList = new ArrayList<>(); final CountDownLatch latch = new CountDownLatch(endPort - startPort + 1); for (int port = startPort; port <= endPort; port++) { int finalPort = port; Thread thread = new Thread(new Runnable() { @Override public void run() { try { Socket socket = new Socket(); socket.connect(new InetSocketAddress(host, finalPort), 100); System.out.println("TCP端口" + finalPort + "开放"); portList.add(finalPort); } catch (Exception e) { } try { DatagramSocket dsocket = new DatagramSocket(finalPort); dsocket.close(); } catch (SocketException e) { portList.add(finalPort); System.out.println("UDP端口" + finalPort + "开放"); } latch.countDown(); } }); thread.start(); } latch.await(); portList.sort(new Comparator<Integer>() { @Override public int compare(Integer o1, Integer o2) { return o1.compareTo(o2); } }); } }

port = q.get() try: s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) s.settimeout(1) s.connect((host, port)) print("TCP端口{}开放".format(port)) portList.append(port) except: pass try: ...

class TaskPollRunnable implements Runnable { @Override public void run() { try { FileCleanTaskResponse poll = pollTasks(1); List<FileCleanTask> tasks = poll.getCleanTasks(); log.info("cleantasks:" + tasks); if (tasks.isEmpty()) { try { Thread.sleep(60000); } catch (InterruptedException e) { log.error("InterruptedException while sleeping",e); } } long startTimeMills = System.currentTimeMillis(); List<Future> futures = new ArrayList<>(); for (FileCleanTask task : tasks) { List<String> dirs = task.getCleanDirs(); log.info("cleandirs:" + dirs); dirs.stream().forEach(dir -> { Future future = executor.submit(new FileCleanRunnable(dir)); futures.add(future); }); } //等待所有线程执行结束 for (Future future : futures) { try { future.get(); } catch (InterruptedException e) { log.error("clean task interupt", e); } catch (ExecutionException e) { log.error("clean task ", e); } } log.info("ALL File clean thread finish,cost: {} ms", (System.currentTimeMillis() - startTimeMills)); } catch (Exception e) { log.error("TaskPollRunnable failed",e); } } 写UT，覆盖异常

public void testTaskPollRunnable() throws Exception { // 构造 mock 对象 FileCleanTaskResponse response = new FileCleanTaskResponse(); List<FileCleanTask> tasks = new ArrayList(); FileCleanTask ...

private class TaskPollRunnable implements Runnable { @Override public void run() { FileCleanTaskResponse poll = pollTasks(1); List<FileCleanTask> tasks = poll.getCleanTasks(); log.info("cleantasks:"+tasks); if(tasks.isEmpty()){ try { Thread.sleep(60000); } catch (InterruptedException e) { e.printStackTrace(); } } long startTimeMills = System.currentTimeMillis(); List<Future> futures = new ArrayList<>(); for(FileCleanTask task : tasks){ List<String> dirs = task.getCleanDirs(); log.info("cleandirs:"+dirs); dirs.stream().forEach(dir->{ Future future = executor.submit(new FileCleanRunnable(dir));//1个网元1个线程 futures.add(future); }); } //等待所有线程执行结束 for(Future future:futures){ try { future.get(); } catch (InterruptedException e) { log.error("clean task interupt",e); } catch (ExecutionException e) { log.error("clean task ",e); } } log.info("ALL File clean thread finish,cost: {} ms",(System.currentTimeMillis() - startTimeMills)); }写 ut

public void testTaskPollRunnable() throws ExecutionException, InterruptedException { // 准备测试数据 FileCleanTaskResponse response = new FileCleanTaskResponse(); List<FileCleanTask> tasks = new ...

以下代码无法运行，请修改以下：public class MainActivity4 extends AppCompatActivity { public static final String TAG = "petgrowing"; TextView show; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main4); show = findViewById(R.id.tv_res); } public void onClick(View btn) { Log.i(TAG, "onClick"); // 使用 Runnable 接口来动态创建新线程 new Thread(() -> { Log.i(TAG, "线程已运行"); try { Log.i(TAG, "run:正在工作..."); Document doc = Jsoup.connect("https://chl.cn/?jinri").get(); Log.i(TAG, "title=" + doc.title()); Elements tables = doc.getElementsByTag("table"); Element table1 = tables.first(); Log.i(TAG, "run:table=" + table1); Elements tds = table1.getElementsByTag("td"); Element td1 = tds.first(); Element td2 = tds.get(4); final String retStr = ("1:" + td1.text() + " 2:" + td2.text()); // 根据获取的数据更新 UI 线程上 TextView 的内容 runOnUiThread(() -> show.setText(retStr)); } catch (MalformedURLException e) { throw new RuntimeException(e); } catch (IOException e) { throw new RuntimeException(e); } }).start(); // 启动新线程 } }

new Thread(() -> { Log.i(TAG, "线程已运行"); try { Log.i(TAG, "run:正在工作..."); Document doc = Jsoup.connect("https://chl.cn/?jinri").get(); Log.i(TAG, "title=" + doc.title()); Elements ...

解析该代码： SharedData.java public class SharedData { private int data; private boolean available = false; public synchronized void setData(int data) { while (available) { try { wait(); } catch (InterruptedException e) { e.printStackTrace(); } } this.data = data; available = true; notifyAll(); } public synchronized int getData() { while (!available) { try { wait(); } catch (InterruptedException e) { e.printStackTrace(); } } available = false; notifyAll(); return data; } } Producer.java public class Producer implements Runnable { private SharedData sharedData; private int producerId; public Producer(SharedData sharedData, int producerId) { this.sharedData = sharedData; this.producerId = producerId; } @Override public void run() { for (int i = 0; i < 10; i++) { sharedData.setData(i); System.out.println("Producer " + producerId + " produced: " + i); try { Thread.sleep((int) (Math.random() * 100)); } catch (InterruptedException e) { e.printStackTrace(); } } } } Consumer.java public class Consumer implements Runnable { private SharedData sharedData; private int consumerId; public Consumer(SharedData sharedData, int consumerId) { this.sharedData = sharedData; this.consumerId = consumerId; } @Override public void run() { for (int i = 0; i < 10; i++) { int data = sharedData.getData(); System.out.println("Consumer " + consumerId + " consumed: " + data); try { Thread.sleep((int) (Math.random() * 100)); } catch (InterruptedException e) { e.printStackTrace(); } } } } Main.java public class Main { public static void main(String[] args) { SharedData sharedData = new SharedData(); Producer producer1 = new Producer(sharedData, 1); Producer producer2 = new Producer(sharedData, 2); Consumer consumer1 = new Consumer(sharedData, 1); Consumer consumer2 = new Consumer(sharedData, 2); Thread t1 = new Thread(producer1); Thread t2 = new Thread(producer2); Thread t3 = new Thread(consumer1); Thread t4 = new Thread(consumer2); t1.start(); t2.start(); t3.start(); t4.start(); } }

在getData()方法中，如果数据不可用则等待，直到数据可用，然后获取数据，将available设置为false，最后唤醒所有等待线程，表示数据不可用。在Producer类中，有一个SharedData类型的共享数据对象sharedData和一个...

卫星网络容器仿真平台+TC流量控制+SRS&ffmpeg推流.zip

卫星网络容器仿真平台+TC流量控制+SRS&ffmpeg推流

基于AI框架的智能工厂设计思路.pptx

相关推荐

java线程的run()没有返回值怎么办？

网络获取json解析json以及子线程显示

Java/Android 获取网络重定向文件的真实URL的示例代码

卫星网络容器仿真平台+TC流量控制+SRS&ffmpeg推流.zip

基于AI框架的智能工厂设计思路.pptx

最新推荐

Android中Glide获取缓存大小并清除缓存图片

java线程池实现批量下载文件

futuretask用法及使用场景介绍

卫星网络容器仿真平台+TC流量控制+SRS&amp;ffmpeg推流.zip

基于AI框架的智能工厂设计思路.pptx

BSC关键绩效财务与客户指标详解

管理建模和仿真的文件

【实战演练】俄罗斯方块：实现经典的俄罗斯方块游戏，学习方块生成和行消除逻辑。

卷积神经网络实现手势识别程序

绘制企业战略地图：从财务到客户价值的六步法

卫星网络容器仿真平台+TC流量控制+SRS&ffmpeg推流.zip