`

java线程初步

阅读更多

Java 线程初步

 

 

http://chuhanzhi.com/?p=66 点击链接看整理后的文章

创建线程两种方法:

1.       继承 Thread 类,并覆盖其中 run 方法如下:

 

package thread;
 
public class FirstThread extends Thread {// 直接继承 Thread 类

    @Override
    public void run() {
        while (true) {
            System.out.println(1);
            System.out.println(this.getName());
        }
    }
 
    public static void main(String[] args) {
        FirstThread th = new FirstThread();
        th.setName("th1");
        th.start();
        Thread th2=new Thread(new SecondThread(),"th2");
        Thread th3 =new Thread(th2,"th3");// 因为 Thread 本身实现了 Runnable 接口所以 Thread 可以作为 Thread 构造函数的参数当然很少会这么做
        th2.start();
        th3.start();
    }
}

 

 

2.       实现 Rannable ,这样就可以使线程可以再继承其它类接口如下:

 

package thread;

 

public class SecondThread implements Runnable {

    @Override

    public void run() {

        while (true) {

            System.out.println("2");

            System.out.println(Thread.currentThread().getName());

        }

    }

} 

 

停止线程:

1.       当线程正常结束时可以终止,在 FirstThread run 方法改为既可以在执行完后自动退出

 

  public void run() {

            System.out.println(1);

            System.out.println(this.getName());

    }

  

  

2.       使用标记使线程停止

 

package thread;

 

import java.util.concurrent.BlockingQueue;

import java.util.logging.Level;

import java.util.logging.Logger;

 

public class FlagStopThread extends Thread {

    public volatile boolean exit = false;

    @Override

    public void run() {

        while (!exit) {

            System.out.println("111111111");// 注意这里面不要是能产生阻塞的操作,如阻塞队列的 put 操作,这样的话可能会不往下执行,从而不会对 exit 进行及时的检查,而不能停止线程的执行

                                             // 而当有这种情况发生时,使用中断来结束线程是一个比较好的选择

        }

//        BlockingQueue queue = null;// 不可取消的任务在退出前保存中断

//        boolean interrupt=false;

//        while(true){

//            try {

//                queue.take();

//             } catch (InterruptedException ex) {

//                interrupt=true;

//            }finally{

//                if(interrupt){

//                    Thread.currentThread().interrupt();

//                }

//            }

//        }

    }

 

    public static void main(String[] args) throws InterruptedException {

        FlagStopThread stopThread = new FlagStopThread();

        stopThread.start();

        sleep(1000);// 主线程休眠

        stopThread.exit = true;

        System.out.println("stop.........");

        //stopThread.join();

    }

} 

 

3.       使用 interrupt 停止

 

package thread;

 

public class InterruptStopThread extends Thread {

    // 使用 interrupt 中断线程

 

    /**

     * interrupt 设置线程的中断状态

     * isInterrupted 判断线程是否中断

     * interrupted 静态方法 判断当前线程中断状态,并且还会将该线程的中断状态置为 false ,因此连续两次调用该方法,

     * 第二次返回值为 false (当然这连续的两次调用之间该线程又被中断的情况除外)

     */

    @Override

    public void run() {

        while (!Thread.currentThread().isInterrupted()) {

            try {

                System.out.println("11111111111" + this.isInterrupted());

                 sleep(1000);// 在 sleep 时调用了 interrupt 后状态标志位就变为 true , sleep 等阻塞方法会不断检查线程的状态,

                            // 当阻塞时会抛出异常进入 catch 块中,同时将标志重置为 false (这是在 sleep 等阻塞方法中完成的)

            } catch (InterruptedException ex) {

                /**

                 * 抛出异常是为了线程从阻塞状态醒过来,并在结束线程前让程序员有足够的时间来处理中断请求。

                 */

                System.out.println(this.isInterrupted()+" 处理中断请求 ");

                this.interrupt();// 再次将中断标志设为 true 使 while 循环结束,该线程终止//不用这样的话try直接包住while块

               

            } finally {

            }

        }

    }

 

    public static void main(String[] args) throws InterruptedException {

        InterruptStopThread interruptStopThread = new InterruptStopThread();

        interruptStopThread.start();

        sleep(1000);

        interruptStopThread.interrupt();

         System.out.println(interruptStopThread.isInterrupted()+"5555");

    }

} 

 

4.       还有 stop 等不推荐的方法

不推荐就不深研究了

sleep join wait notify 方法

wait方法:

 

package thread;

 

import java.util.logging.Level;

import java.util.logging.Logger;

 

public class SleepThread extends Thread {

 

    @Override

    public void run() {

        try {

            while (true) {

                System.out.println("1111111111...");

                 sleep(1000);//sleep 有两个重载形式,另一个重载形式不仅可以设置毫秒还可以设置纳秒但大多数操作系统上的 java 虚拟机都无法精确到秒这时就会取近似的毫秒值

                //suspend(); 挂起和唤醒线程,不建议使用

                //resume();

            }

 

        } catch (InterruptedException ex) {// 在这里 run 方法无法使用 throws 因此只能使用 try{}catch(){}, 当在休眠过程中使用 interrupt 方法时会 sleep 会抛出一个 InterruptedException 异常

            System.out.println("111");

        }

    }

 

    public static void main(String[] args) {

        SleepThread sleepThread = new SleepThread();

        sleepThread.start();

    }

} 

 

join方法

 

 

 

 

package thread;

 

import java.util.logging.Level;

import java.util.logging.Logger;

 

public class JoinThread extends Thread {

 

    /**

     * 如果简单数据类型声明为 volatile ,对它们的操作就会变成原子级别的。但这有一定的限制。要对表达式加上 synchronized 关键字

     *

     * Java 的内存模型分为主存储区和工作存储区。

     * 主存储区保存了 Java 中所有的实例。也就是说,在我们使用 new 来建立一个对象后,这个对象及它内部的方法、变量等都保存在这一区域,

     * 在 Jointhread 类中的 n 就保存在这个区域。主存储区可以被所有线程共享。而工作存储区就是我们前面所讲的线程栈,

     * 在这个区域里保存了在 run 方法以及 run 方法所调用的方法中定义的变量,也就是方法变量。

     * 在线程要修改主存储区中的变量时,并不是直接修改这些变量,而是将它们先复制到当前线程的工作存储区,

     * 在修改完后,再将这个变量值覆盖主存储区的相应的变量值。由此可见 n++ 并非原子操作

     */

    public volatile static int n = 0;

 

    @Override

    public void run() {

        for (int i = 0; i < 100; i++) {

            n = n + 1;

            try {

                sleep(1000);// 这里 n=n+1 不是原子级别的。为了使结果更随机,延迟一段时间

            } catch (InterruptedException ex) {

                Logger.getLogger(JoinThread.class.getName()).log(Level.SEVERE, null, ex);

            }

            System.out.println(Thread.currentThread().getName() + "  n=" + n);

        }

 

    }

 

    public static void main(String[] args) {

        JoinThread[] joinThreads = new JoinThread[3];

        for (int i = 0; i < joinThreads.length; i++) {

             joinThreads[i] = new JoinThread();

        }

        for (int i = 0; i < joinThreads.length; i++) {

            joinThreads[i].setName("thread" + i);

            joinThreads[i].start();

//            try {

//                joinThreads[i].join();

//            } catch (InterruptedException ex) {

//                Logger.getLogger(JoinThread.class.getName()).log(Level.SEVERE, null, ex);

//            }

        }

        System.out.println("n=" + n);

    }

}

  

 

 

 

synchronized

 

package thread;

//http://stackoverflow.com/questions/437620/java-synchronized-methods-lock-on-object-or-class/437627#437627

public class Synchronized1Thread implements Runnable {

 

    public String methodName;

//    public synchronized void method1() {

//        while (true) {

//            System.out.println("1111111" + Thread.currentThread().getName() + "   " + methodName);

//

//        }

//    }

//method1 可以等同于写成以下方法

    public  void method1() {

        synchronized (this) {

            while (true) {

                System.out.println("1111111" + Thread.currentThread().getName() + "   " + methodName);

 

            }

        }

 

    }

 

    public synchronized void method2() {

        while (true) {

            System.out.println("2222222");

        }

     }

 

    public static synchronized void method3() {

        while (true) {

            System.out.println("3333333" + Thread.currentThread().getName());

        }

    }

//method3 等同于以下方法

//    public static  void method3() throws ClassNotFoundException {

//        synchronized (Class.forName("Synchronized1Thread")) {

//            while (true) {

//                System.out.println("3333333" + Thread.currentThread().getName());

//            }

//        }

//    }

 

    public static synchronized void method4() {

        while (true) {

            System.out.println("4444444");

        }

    }

 

    @Override

    public void run() {

        try {

            this.getClass().getMethod(methodName).invoke(this);

        } catch (Exception e) {

            e.printStackTrace();

        }

    }

 

    public static void main(String[] args) throws InterruptedException {

        /*

         * 一个 synchronized 方法执行时需要一个锁(监视器)

         * 一个对象只有且只能提供一个锁

         * 对于静态方法有 synchronized 时它的锁是所在类的 Class 对象 所以静态方法和非静态方法不管在什么情况下都是可以并发执行的,

         * 因为不同方法上加锁的对象是不同的(非静态方法的锁是类的一个实例对象,而静态方法则是所在类的 Class 对象)

         */

        Synchronized1Thread syn1 = new Synchronized1Thread();

        Synchronized1Thread syn2 = new Synchronized1Thread();

        syn1.methodName = "method1";

        syn2.methodName = "method4";

        new Thread(syn1).start();

        Thread.sleep(100);// 加一个延迟使上面那个线程有足够时间运行到 run 方法中去

        new Thread(syn2).start();//1 1 (此时加锁的是不同的实例对象), 1 2 , 1 3 可同时进入,但 3 3 , 3 4 不可同时进入( 1 1 指的是不同进程运行 method1 和 method1 能否并发执行)

 

//        Synchronized1Thread syn1 = new Synchronized1Thread();

//        syn1.methodName = "method1";

//        new Thread(syn1).start();

//        Thread.sleep(100);

//        syn1.methodName = "method3";

//

//        new Thread(syn1).start();;//1 2 , 1 1 不可同时进入, 1 3 可以说明静态方法和非静态方法无影响

 

 

    }

}

 

 

 

wait方法

package thread;

 

import java.util.logging.Level;

import java.util.logging.Logger;

 

public class WaitThread {

    /*

     * wait 使方法临时阻塞跟 sleep join 等相似,但它将线程置于睡眠状态之后还会积极的等待条件发生改变。

     * 在一个 notify 或 notifyAll 后会唤醒等待的线程重新可以运行。

     * 在使用 notify 时要注意如果有多个线程是因调用一个对象的 wait 方法而阻塞的那么 notify 会随机选择一个被阻塞的线程解除阻塞,这时可用 notifyAll

     * 调用任意对象的 wait() 方法导致线程阻塞,并且该对象上的锁被释放。

     * 而调用任意对象的 notify() 方法则导致因调用该对象的 wait() 方法而阻塞的线程中随机选择的一个解除阻塞(但要等到获得锁后才真正可执行)

     * 要释放锁的前提当然是要有锁因此有 wait 的地方一定有 synchronized ,只有 synchronized 方法或块中当前线程才占有锁,才有锁可以释放

     */

 

    public static void main(String[] args) {

        NotifyThread notifyThread = new NotifyThread();

        System.out.println("result is coming soon...");

        notifyThread.start();

//        try {// 如果加上这句可能就是先执行了 notify 再执行下面的 wait 会阻塞,因此实际运行 wait 或 notify 时应根据情况进行条件检查

//            Thread.sleep(1000);

//        } catch (InterruptedException ex) {

//            Logger.getLogger(WaitThread.class.getName()).log(Level.SEVERE, null, ex);

//        }

        synchronized (notifyThread) {

            try {

                notifyThread.wait();

                //notifyThread.wait();// 如果加上这个当被原来那个 wait 的阻塞被解除后又运行这个 wait 后又阻塞了,因为没有别的线程可以为其解除阻塞所以会一直阻塞下去

            } catch (InterruptedException ex) {

                Logger.getLogger(WaitThread.class.getName()).log(Level.SEVERE, null, ex);

            }

        }

        System.out.println("result is:" + notifyThread.a);

    }

}

 

class NotifyThread extends Thread {

 

    public Integer a = 0;

 

    @Override

    public void run() {

        synchronized (this) {

            for (int i = 0; i < 101; i++) {

                a = a + i;

            }

            notify();

        }

    }

} 

 

生产者消费者

 

package thread;

 

import java.util.Random;

import java.util.logging.Level;

import java.util.logging.Logger;

 

public class CustomerProducterThread {

 

    public static void main(String[] args) {

        Storage storage = new Storage();

        Customer c1 = new Customer(storage);

        c1.setName("c1");

        Customer c2 = new Customer(storage);

        c2.setName("c2");

        Customer c3 = new Customer(storage);

        c3.setName("c3");

        Customer c4 = new Customer(storage);

        c4.setName("c4");

        Producter p1 = new Producter(storage);

        p1.setName("p1");

        Producter p2 = new Producter(storage);

        p2.setName("p2");

        Producter p3 = new Producter(storage);

        p3.setName("p3");

        Producter p4 = new Producter(storage);

        p4.setName("p4");

        c1.start();

        c2.start();

        p1.start();

        p2.start();

        p3.start();

        p4.start();

        c3.start();

        c4.start();

 

    }

}

 

class Storage {// 仓库

 

    public static final int[] lock = new int[0];

    public static final Integer max = 100;

    private Integer sto = 0;

 

    public void put(int i, String name) {// 生产者放

        synchronized (lock) {

            if ((this.sto + i) > max) {

                System.out.println(name + " 仓库已满 ............" + i);

                try {

                    lock.wait();

                    put(i,name);// 等 wait 结束后继续调用 put 方法来放置刚才生产的 i 个产品 , 即生产的产品放不进时不能丢,等解锁后再放

                } catch (InterruptedException ex) {

                     Logger.getLogger(Storage.class.getName()).log(Level.SEVERE, null, ex);

                }

            } else {

                this.sto = this.sto + i;

                System.out.println(name + " 生产了 " + i + " 个产品,现在库存量 " + this.sto);

                lock.notifyAll();

            }

        }

    }

 

    public void get(int i, String name) {// 消费者取

        synchronized (lock) {

            if (this.sto - i < 0) {

                System.out.println(name + " 仓库余额不足 ............" + i);

                 try {

                    lock.wait();

                    get(i,name);

                } catch (InterruptedException ex) {

                    Logger.getLogger(Storage.class.getName()).log(Level.SEVERE, null, ex);

                }

            } else {

                this.sto = this.sto - i;

                System.out.println(name + " 消费了 " + i + " 个产品,现在库存量 " + this.sto);

                lock.notifyAll();

            }

 

 

        }

    }

}

 

class Customer extends Thread {// 消费者

 

    public Storage sto;

 

    public Customer(Storage sto) {

        this.sto = sto;

    }

 

    @Override

    public void run() {

        while (true) {

            sto.get(new Random().nextInt(10) + 1, Thread.currentThread().getName());

        }

 

    }

}

 

class Producter extends Thread {// 生产者

 

    public Storage sto;

 

    public Producter(Storage sto) {

        this.sto = sto;

    }

 

    @Override

    public void run() {

        while (true) {

            sto.put(new Random().nextInt(10) + 1, Thread.currentThread().getName());

        }

 

    }

} 

 

 

Dead Lock简单实例

 

package thread;

 

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

 

public class LeftRightDeadLockThread {

 

    private Object left = new Object();

    private Object right = new Object();

 

    public void leftRight() {

        synchronized (left) {

            synchronized (right) {

                System.out.println("leftRight");

            }

        }

    }

 

    public void rightLeft() {

        synchronized (right) {

            synchronized (left) {

                System.out.println("rightLeft");

            }

        }

    }

    /*

     * A- 锁住 left- 尝试锁住 right-- 永远等待

     *  B- 锁住 right- 尝试锁住 left-- 永远等待

     */

 

    public static void main(String[] args) {

        final LeftRightDeadLockThread lRDLT = new LeftRightDeadLockThread();

        ExecutorService service = Executors.newFixedThreadPool(2);

        service.submit(new Runnable() {

 

            @Override

            public void run() {

                while (true) {

                    lRDLT.leftRight();

                }

            }

        });

        service.submit(new Runnable() {

 

            @Override

            public void run() {

                while (true) {

                    lRDLT.rightLeft();

                }

            }

        });

        service.shutdown();

    }

} 

  ThreadLocal:

//ThreadLocal的get方法
// public T get() {
//        Thread t = Thread.currentThread();
//        ThreadLocalMap map = getMap(t);//getMap(t)方法内部就是return t.threadLocals; 可见每个线程都有一个ThreadLocalMap的threadLocals属性
//        if (map != null) {
//            ThreadLocalMap.Entry e = map.getEntry(this);//如果该map不为空的话以该ThreadLocal的实例对象为key取出值并返回
//            if (e != null)
//                return (T)e.value;
//        }
//        return setInitialValue();//如果map为空或不为空但以此ThreadLocal的实例对象为key在map中取值为空时就调用此方法
//    }
//setInitialValue()方法
//private T setInitialValue() {
//        T value = initialValue();//initialValue()方法默认是返回空的,但是它是一个protected方法是为了子类重写准备的,因此如果多个线程要不相互干扰的使用同一个变量的时候,就可以重写这个方法然后new一个新的引用将那个变量的初值赋值给这个引用的对象就可以了
//        Thread t = Thread.currentThread();
//        ThreadLocalMap map = getMap(t);
//        if (map != null)
//            map.set(this, value);
//        else
//            createMap(t, value);
//        return value;
//    }
//set方法
//public void set(T value) {
//        Thread t = Thread.currentThread();
//        ThreadLocalMap map = getMap(t);
//        if (map != null)
//            map.set(this, value);
//        else
//            createMap(t, value);
//    }
/**
 * 综上可以看到ThreadLocal set 和 get的使用过程:
 * 从set说起:
 * 1.取得执行当前代码的线程
 * 2.从取得的线程中取其ThreadLocalMap 的对象属性
 * 3.以ThreadLocal为key往上面取得的map中放值
 * 下面是get方法:
 * 1.取得执行当前代码的线程
 * 2.从取得的线程中取其ThreadLocalMap 的对象属性
 * 3.map不为空以此ThreadLocalMap为键取值,如果取得值不为空则返回这个值。
 * 如果为空或map本身为空则需返回initialValue方法中的值
 * 上面的总结可以看出,ThreadLocal set()时可以将一个需要每个线程都分别存放的对象放到正在运行该方法的线程的ThreadLocalMap中 
 * get的时候再从正在运行的线程的ThreadLocalMap中取得这个对象,因此每个线程都能从自己的ThreadLocalMap中取得自己保存的值
 * 
 * ThreadLocal适应的场合应该是每个线程对应一个实例的访问,用它的作用话应该是:可以使代码变得更“优雅”一些而避免了参数传递的麻烦,比如说在一个线程中
 * 多个方法都需要一个变量而且是共享的,那么这个变量就可以放到ThreadLoca中,这看起来跟session有点像
 */
package thread;

import org.hibernate.HibernateException;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.cfg.Configuration;

public class ThreadLocalThread {//没有好例子暂时用这个吧
//
//    ThreadLocal threadLocal = new ThreadLocal() {
//
//        protected synchronized Object initialValue() {
//            return new Integer(0);
//        }
//    };
    public static final SessionFactory sessionFactory;

    static {
        try {
            sessionFactory = new Configuration().configure().buildSessionFactory();
        } catch (Throwable ex) {
            throw new ExceptionInInitializerError(ex);
        }
    }
    public static final ThreadLocal session =new ThreadLocal();

    public static Session currentSession() throws HibernateException {//这样就能保证在每个线程中取得的Session是每个线程自己的那一个
        Session s = (Session) session.get();
        if (s == null) {
            s = sessionFactory.openSession();
            session.set(s);
        }
        return s;
    }

    public static void closeSession() throws HibernateException {
        Session s = (Session) session.get();
        if (s != null) {
            s.close();
        }
        session.set(null);
    }
}

 

 

 

分享到:
评论

相关推荐

    Tripple Farm:Match 3 Combination Game Complete Project 合成小镇三消Unity合成消除游戏项目游戏插件模版C#

    Tripple Farm:Match 3 Combination Game Complete Project 合成小镇三消Unity合成消除游戏项目游戏插件模版C# 支持Unity2020.3.4或更高 您知道像三合镇这样的著名益智游戏,并且您想制作一个自己的游戏。就是这样。这个包正好适合您。 这是一个完整的项目,您可以在零分钟内将其上传到 appstore 或 googleplay 商店。 基本规则: 3个或以上相同的道具可以匹配升级为新的道具。动物如果被困住,也可以合并。 羽毛: -移动(android/ios)就绪。 - 包含所有源代码。 -超过 12 座建筑/军团需要升级。 -三种特殊物品可以提供帮助。 - 三个不同的主题(场景和动物) -unity iap 支持 -Unity UI -广告位已准备好 -包含详细文档

    【JAVA编程基础】针对新手的JAVA基础测试题:涵盖选择题、简答与编程实践

    内容概要:本文档是一份针对Java初学者的基础测试题,分为不定项选择题、简答题和编程题三大部分。选择题涵盖标识符、数组初始化、面向对象概念、运算符优先级、循环结构、对象行为、变量命名规则、基本

    MATLAB机器人运动学、动力学及轨迹规划的建模与仿真

    内容概要:本文详细介绍了如何利用MATLAB进行机器人运动学、动力学以及轨迹规划的建模与仿真。首先,通过具体的代码实例展示了正运动学和逆运动学的实现方法,包括使用DH参数建立机械臂模型、计算末端位姿以及求解关节角度。接着,讨论了雅克比矩阵的应用及其在速度控制中的重要性,并解释了如何检测和处理奇异位形。然后,深入探讨了动力学建模的方法,如使用拉格朗日方程和符号工具箱自动生成动力学方程。此外,还介绍了多种轨迹规划技术,包括抛物线插值和五次多项式插值,确保路径平滑性和可控性。最后,提供了常见仿真问题的解决方案,强调了在实际工程项目中需要注意的关键点。 适合人群:对机器人控制感兴趣的初学者、希望深入了解机器人运动学和动力学的学生及研究人员、从事机器人开发的技术人员。 使用场景及目标:① 学习如何使用MATLAB进行机器人运动学、动力学建模;② 掌握不同类型的轨迹规划方法及其应用场景;③ 解决仿真过程中遇到的各种问题,提高仿真的稳定性和准确性。 其他说明:文中提供的代码片段可以直接用于实验和教学,帮助读者更好地理解和掌握相关概念和技术。同时,针对实际应用中的挑战提出了实用的建议,有助于提升项目的成功率。

    基于单片机的无线环境监测-仿真设计(51x2+12864+18B20+HW).#0092

    包括:源程序工程文件、Proteus仿真工程文件、配套技术手册等 1、采用51/52单片机作为主控芯片; 2、发送机:18B20测温、开关模拟灯光,发送数据; 3、接收机:接受数据、12864液晶显示;

    微电网优化中风光不确定性的处理:基于机会约束与概率序列的Matlab实现

    内容概要:本文探讨了在微电网优化中如何处理风光能源的不确定性,特别是通过引入机会约束和概率序列的方法。首先介绍了风光能源的随机性和波动性带来的挑战,然后详细解释了机会约束的概念,即在一定概率水平下放松约束条件,从而提高模型灵活性。接着讨论了概率序列的应用,它通过对历史数据分析生成多个可能的风光发电场景及其概率,以此为基础构建优化模型的目标函数和约束条件。文中提供了具体的Matlab代码示例,演示了如何利用CPLEX求解器解决此类优化问题,并强调了参数选择、模型构建、约束添加以及求解过程中应注意的技术细节。此外,还提到了一些实用技巧,如通过调整MIP gap提升求解效率,使用K-means聚类减少场景数量以降低计算复杂度等。 适合人群:从事电力系统研究、微电网设计与运营的专业人士,尤其是那些对风光不确定性建模感兴趣的研究者和技术人员。 使用场景及目标:适用于需要评估和优化含有大量间歇性可再生能源接入的微电网系统,旨在提高系统的经济性和稳定性,确保在面对风光出力波动时仍能维持正常运作。 其他说明:文中提到的方法不仅有助于学术研究,也可应用于实际工程项目中,帮助工程师们制定更为稳健的微电网调度计划。同时,文中提供的代码片段可供读者参考并应用于类似的问题情境中。

    linux之用户管理教程.md

    linux之用户管理教程.md

    基于组态王与S7-200 PLC的六层至八层电梯控制系统设计与实现

    内容概要:本文详细介绍了如何利用组态王和西门子S7-200 PLC构建六层或八层电梯控制系统。首先进行合理的IO地址分配,明确输入输出信号的功能及其对应的物理地址。接着深入解析了PLC源代码的关键部分,涵盖初始化、呼叫处理、电梯运行逻辑和平层处理等方面。此外,提供了组态王源代码用于实现动画仿真,展示了电梯轿厢的画面创建及动画连接方法。最后附上了详细的电气原理图和布局图,帮助理解和实施整个系统架构。 适合人群:从事工业自动化控制领域的工程师和技术人员,尤其是对PLC编程和人机界面开发感兴趣的从业者。 使用场景及目标:适用于教学培训、工程项目实践以及研究开发等场合。旨在为相关人员提供一个完整的电梯控制系统设计方案,便于他们掌握PLC编程技巧、熟悉组态软件的应用,并能够独立完成类似项目的开发。 其他说明:文中不仅包含了理论知识讲解,还分享了许多实际操作经验,如解决编码器丢脉冲的问题、优化平层停车精度的方法等。同时强调了安全性和可靠性方面的考虑,例如设置了多重保护机制以确保系统稳定运行。

    基于MTF的1D-2D-CNN-LSTM-Attention时序图像多模态融合的故障识别,适合研究学习(Matlab完整源码和数据)

    在工业生产和设备运行过程中,滚动轴承故障、变压器油气故障等领域的数据分类与故障诊断至关重要。准确的数据分类与故障诊断能够及时发现设备潜在问题,避免故障恶化导致的生产事故与经济损失。LSTM能够捕获时序信息,马尔可夫场(MTF)能够一维信号转换为二维特征图,并结合CNN学习空间特征,MTF-1D-2D-CNN-LSTM-Attention模型通过将一维时序信号和二维图像融合,融合不同模态优势,并引入多头自注意力机制提高泛化能力,为数据分类与故障诊断提供了新的思路。实验结果表明,该模型在分类准确率、鲁棒性和泛化能力方面具有显著优势。多模态融合算法凭借其创新点和实验验证的有效性,在滚动轴承故障、变压器油气故障等领域展现出广阔的应用前景,有望推动相关领域故障诊断技术的进一步发展。 关键词:多模态融合;故障诊断;马尔可夫场;卷积神经网络;长短期记忆神经网络 适用平台:Matlab2023版本及以上。实验硬件设备配置如下:选用高性能计算机,搭载i7处理器,以确保数据处理和模型训练的高效性;配备16GB的内存,满足大规模数据加载和模型运算过程中的内存需求;使用高性能显卡,提供强大的并行计算能力,加速深度学习模型的训练过程。实验参数的选择依据多方面因素确定。

    【面试模拟系统AI提示词】基于简历和岗位要求的个性化模拟面试(deepseek,豆包,kimi,chatGPT,扣子空间,manus,AI训练师)

    内容概要:本文档提供了一个面试模拟的指导框架,旨在为用户提供一个真实的面试体验。文档中的面试官名为Elian,被设定为性格温和冷静且思路清晰的形象,其主要职责是根据用户提供的简历信息和应聘岗位要求,进行一对一的模拟面试。面试官将逐一提出问题,确保每次只提一个问题,并等待候选人的回答结束后再继续下一个问题。面试官需要深入了解应聘岗位的具体要求,包括但不限于业务理解、行业知识、具体技能、专业背景以及项目经历等方面,从而全面评估候选人是否符合岗位需求。此外,文档强调了面试官应在用户主动发起提问后才开始回答,若用户未提供简历,面试官应首先邀请用户提供简历或描述应聘岗位; 适用人群:即将参加面试的求职者,特别是希望提前熟悉面试流程、提升面试技巧的人士; 使用场景及目标:①帮助求职者熟悉面试流程,提高应对实际面试的信心;②通过模拟面试,让求职者能够更好地展示自己的优势,发现自身不足之处并加以改进; 其他说明:此文档为文本格式,用户可以根据文档内容与面试官Elian进行互动,以达到最佳的模拟效果。在整个模拟过程中,用户应尽量真实地回答每一个问题,以便获得最贴近实际情况的反馈。

    招聘技巧HR必看如何进行网络招聘和电话邀约.ppt

    招聘技巧HR必看如何进行网络招聘和电话邀约.ppt

    三菱PLC与组态王构建3x3书架式堆垛立体库:IO分配、梯形图编程及组态画面设计

    内容概要:本文详细介绍了利用三菱PLC(特别是FX系列)和组态王软件构建3x3书架式堆垛式立体库的方法。首先阐述了IO分配的原则,明确了输入输出信号的功能,如仓位检测、堆垛机运动控制等。接着深入解析了梯形图编程的具体实现,包括基本的左右移动控制、复杂的自动寻址逻辑,以及确保安全性的限位保护措施。还展示了接线图和原理图的作用,强调了正确的电气连接方式。最后讲解了组态王的画面设计技巧,通过图形化界面实现对立体库的操作和监控。 适用人群:从事自动化仓储系统设计、安装、调试的技术人员,尤其是熟悉三菱PLC和组态王的工程师。 使用场景及目标:适用于需要提高仓库空间利用率的小型仓储环境,旨在帮助技术人员掌握从硬件选型、电路设计到软件编程的全流程技能,最终实现高效稳定的自动化仓储管理。 其他说明:文中提供了多个实用的编程技巧和注意事项,如避免常见错误、优化性能参数等,有助于减少实际应用中的故障率并提升系统的可靠性。

    COMSOL电弧放电模型:基于磁流体方程的多物理场耦合仿真及其应用

    内容概要:本文详细探讨了利用COMSOL进行电弧放电现象的模拟,重点在于采用磁流体方程(MHD)来耦合电磁、热流体和电路等多个物理场。文中介绍了关键的数学模型如磁流体动力学方程、热传导方程以及电路方程,并讨论了求解过程中遇到的技术难题,包括参数敏感性、求解器选择、网格划分等问题。此外,作者分享了许多实践经验,比如如何处理不同物理场之间的相互作用,怎样避免数值不稳定性和提高计算效率。 适用人群:适用于从事电弧放电研究的专业人士,尤其是那些希望通过数值模拟深入了解电弧行为并应用于实际工程项目的人群。 使用场景及目标:①帮助研究人员更好地理解和预测电弧放电过程中的各种物理现象;②为工程师提供优化电气设备设计的方法论支持;③指导使用者正确配置COMSOL软件的相关参数以确保高效稳定的仿真结果。 其他说明:尽管存在较高的计算复杂度和技术挑战,成功的电弧放电仿真能够显著提升对这一重要物理过程的认识水平,并促进相关领域的技术创新和发展。

    基于粒子群优化的KELM算法在多维输入单维输出数据处理中的应用与性能提升

    内容概要:本文详细介绍了如何利用粒子群优化算法(PSO)改进极限学习机(KELM),以提升其在多维输入单维输出数据处理任务中的性能。首先简述了KELM的工作原理及其快速训练的特点,接着深入探讨了PSO算法的机制,包括粒子的速度和位置更新规则。然后展示了如何将PSO应用于优化KELM的关键参数,如输入权值和隐含层偏置,并提供了具体的Python代码实现。通过对模拟数据和实际数据集的实验对比,证明了PSO优化后的KELM在预测精度上有显著提升,尤其是在处理复杂数据时表现出色。 适合人群:对机器学习尤其是深度学习有一定了解的研究人员和技术爱好者,以及从事数据分析工作的专业人士。 使用场景及目标:适用于需要高效处理多维输入单维输出数据的任务,如时间序列预测、回归分析等。主要目标是通过优化模型参数,提高预测准确性并减少人工调参的时间成本。 其他说明:文中不仅给出了详细的理论解释,还附上了完整的代码示例,便于读者理解和实践。此外,还讨论了一些实用技巧,如参数选择、数据预处理等,有助于解决实际应用中的常见问题。

    基于粒子群算法的微网优化调度Matlab程序设计与实现

    内容概要:本文介绍了利用粒子群算法(PSO)解决微网优化调度问题的方法。主要内容涵盖微网系统的组成(风力、光伏、储能、燃气轮机、柴油机)、需求响应机制、储能SOC约束处理及粒子群算法的具体实现。文中详细描述了目标函数的设计,包括发电成本、启停成本、需求响应惩罚项和SOC连续性惩罚项的计算方法。同时,阐述了粒子群算法的核心迭代逻辑及其参数调整策略,如惯性权重的线性递减策略。此外,还讨论了代码调试过程中遇到的问题及解决方案,并展示了仿真结果,证明了模型的有效性和优越性。 适合人群:从事电力系统优化、智能算法应用的研究人员和技术人员,特别是对微网调度感兴趣的读者。 使用场景及目标:适用于研究和开发微网优化调度系统,旨在提高供电稳定性的同时降低成本。具体应用场景包括但不限于分布式能源管理、工业园区能源调度等。目标是通过合理的调度策略,使微网系统在满足需求响应的前提下,实现经济效益最大化。 其他说明:本文提供的Matlab程序具有良好的模块化设计,便于扩展和维护。建议读者在理解和掌握基本原理的基础上,结合实际情况进行改进和创新。

    【KUKA 机器人资料】:典型机器人案例分析.pdf

    KUKA机器人相关资料

    基于多智能体的高层建筑分阶段火灾疏散仿 真及策略研究.pdf

    基于多智能体的高层建筑分阶段火灾疏散仿 真及策略研究.pdf

    IR2-Net-ACM资源

    Iterative Time Series Imputation by Maintaining Dependency Consistency (ACM TKDD 2024)

    电力电子领域带同步整流桥的交错PFC源代码仿真实现及优化

    内容概要:本文详细探讨了带同步整流桥的交错PFC(功率因数校正)电路的设计与仿真实现。交错PFC通过多路PFC电路交错工作,降低了输入电流纹波,提高了功率密度。同步整流桥采用MOSFET代替传统二极管,减少了整流损耗,提升了效率。文中提供了关键代码片段,包括PWM控制、同步整流桥控制逻辑、电流环控制等,并介绍了如何在MATLAB/Simulink中搭建仿真模型,验证设计方案的有效性。此外,还讨论了仿真过程中遇到的问题及其解决方案,如死区时间处理、电流采样精度、负载突变应对等。 适合人群:从事电力电子设计的研究人员和技术工程师,尤其是对PFC技术和同步整流感兴趣的从业者。 使用场景及目标:适用于研究和开发高效的电源管理系统,旨在提高电能利用率,减少谐波污染,优化电源性能。目标是通过仿真实验验证设计方案的可行性,最终应用于实际硬件开发。 其他说明:文章强调了仿真与实际调试的区别,提醒读者在实际应用中需要注意的细节,如电流采样精度、死区时间和负载突变等问题。同时,提供了具体的代码实现和仿真技巧,帮助读者更好地理解和掌握这一复杂的技术。

    MATLAB实现冷热电气多能互补微能源网的鲁棒优化调度模型

    内容概要:本文详细探讨了MATLAB环境下冷热电气多能互补微能源网的鲁棒优化调度模型。首先介绍了多能耦合元件(如风电、光伏、P2G、燃气轮机等)的运行特性模型,展示了如何通过MATLAB代码模拟这些元件的实际运行情况。接着阐述了电、热、冷、气四者的稳态能流模型及其相互关系,特别是热电联产过程中能流的转换和流动。然后重点讨论了考虑经济成本和碳排放最优的优化调度模型,利用MATLAB优化工具箱求解多目标优化问题,确保各能源设备在合理范围内运行并保持能流平衡。最后分享了一些实际应用中的经验和技巧,如处理风光出力预测误差、非线性约束、多能流耦合等。 适合人群:从事能源系统研究、优化调度、MATLAB编程的专业人士和技术爱好者。 使用场景及目标:适用于希望深入了解综合能源系统优化调度的研究人员和工程师。目标是掌握如何在MATLAB中构建和求解复杂的多能互补优化调度模型,提高能源利用效率,降低碳排放。 其他说明:文中提供了大量MATLAB代码片段,帮助读者更好地理解和实践所介绍的内容。此外,还提及了一些有趣的发现和挑战,如多能流耦合的复杂性、鲁棒优化的应用等。

    基于Simulink的永磁同步电机无位置传感器FOC控制系统仿真与优化

    内容概要:本文详细介绍了如何在Simulink中构建永磁同步电机(PMSM)无位置传感器的磁场定向控制(FOC)系统。主要内容涵盖双闭环PI调节器的设计、SVPWM调制方法、坐标变换、滑模观测器用于无位置估算以及各环节常见问题及其解决方案。文中提供了具体的MATLAB代码示例,如Clarke变换、SVPWM扇区判断、PI调节器抗饱和处理等,并分享了许多实用的调试技巧,如电流环积分限幅、SVPWM扇区判断优化、滑模观测器增益选择等。 适合人群:具有一定电机控制基础的研究人员和技术工程师,尤其是从事电力电子、自动化控制领域的专业人士。 使用场景及目标:适用于希望深入理解并掌握PMSM无位置传感器FOC控制系统的开发者。主要目标是在Simulink环境中搭建完整的FOC控制系统,解决实际应用中的各种技术难点,提高系统的稳定性和精度。 其他说明:文章强调了仿真与实际硬件之间的差异,指出了一些常见的陷阱和应对措施。同时,作者分享了很多个人实践经验,使得复杂的技术概念更加通俗易懂。

Global site tag (gtag.js) - Google Analytics