一、程序

# 事件测试
from threading import Thread, Event
from time import sleep


def car():
    # global count
    num = 0
    while True:
        if event.is_set:
            print('车到站')
            sleep(1)
            # count += 1
            num += 1
            if num % 5 == 0:
                event.clear()
        else:
            print('车开走了')
            sleep(6)
            # count = 1
            event.set()


def person():
    # global count
    while True:
        if event.is_set():
            print('上车')
            sleep(1)
        else:
            print('等车')
            event.wait()


if __name__ == '__main__':
    # count = 1
    event = Event()
    t1 = Thread(target=car)
    #t2 = Thread(target=person)
    t1.start()
    # t2.start()

二、运行结果

三、疑问

老师请问，我这一开始运行结果为啥是‘车到站’，不应该是‘车开走了’了吗？谢谢老师解答

老师我的这个没有缺少jar，静态资源也可以加载到。为什么不行啊

# 配置连接超时
connect_timeout=10
# 网络工作的超时， 一次连接的超时时长。
network_timeout=30
# 连接中的使用字符集
charset=UTF-8
# tracker的http协议端口，和FastDFS中的tracker服务的配置文件tracker.conf中的http.server_port一致
http.tracker_http_port=8080

# tracker服务器的所在地址。 就是IP：port
tracker_server=192.168.86.132:22122
-----------------------------------------------------------------------------------------------------
package com.bjsxt.fdfs.test;

import org.csource.common.MyException;
import org.csource.fastdfs.*;


import java.io.IOException;

public class TestInitClient {

    public static void main(String[] args) {
        //创建FastDFS Java客户端
        try {
            //加载客户端配置文件，就是刚定义的conf配置文件
            ClientGlobal.init("src/main/resources/test/fdfs.conf");
            //创建Tracker服务器的客户端连接对象，
           TrackerClient trackerClient = new TrackerClient();

           //通过Tracker客户端对象，获取Tracker服务端对象
            TrackerServer trackerServer = trackerClient.getConnection();

            //通过Tracker客户端和服务端对象，获取Storage服务端对象
            StorageServer storageServer = trackerClient.getStoreStorage(trackerServer);

            //通过Tracker服务端对象和Storage服务端对象，来创建Storage客户端访问对象，实现文件的上传和下载
            //最终使用的，由于文件处理的对象
            StorageClient storageClient = new StorageClient(trackerServer,storageServer);

            System.out.println("trackerClient:"+trackerClient);
            System.out.println("trackerServer:"+trackerServer);
            System.out.println("storageServer:"+storageServer);
            System.out.println("storageClient:"+storageClient);

        }catch (IOException e1){ //配置文件找不到之类。 IO异常
            e1.printStackTrace();
        }catch (MyException e2){ //FastDFS的java客户端API定义的自定义异常
            //如： tracker服务器连接错误， Storage服务器连接错误
            e2.printStackTrace();
        }
    }

}

老师，请问MacBook应该如何安装Oracle呢？

package com.Jin;

import org.apache.commons.io.IOUtils;

import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;

public class TestIOUtils {
    public static void main(String[] args) throws IOException {
        String str = IOUtils.toString(new FileInputStream("D:\\a.txt"));
        System.out.println(str);
    }
}

为什么toString显示字符串(输入流)'已弃用

结果

14行又出现一个新的Source源   从流当中传入 希望解释一下为什么

这块说创建schemafactory工厂需要用静态方法创建里面需要一个schemalanguage，这个schemalanguage（schema语言）是啥意思呢  然后老师说这里写命名空间 就是这个网址 但是刚才在book.xml中明明说没有写命名空间呀 到这怎么又有命名空间了

这块10行和11行引入是什么意思呢 这个：xsi 在schama里是：xs 这里为什么是xsi呢  还有xsi：noNameapaceSchamaLocation这是啥意思呢  老师说没有命名空间 命名空间是什么 为什么没有 为什么要写成{book.xsd} 

听了好几遍这节课了 还是听不懂

老师13行 那个use是什么意思，还有里面的值老师说是必须要写的  能解释一下吗 就提了一嘴咱也不明白啊

还有这个 ：xs 老师说相当于导包 就是个小名 不太理解  导谁的包啊？  谁的小名啊 为什么之后每个标签前面都要写xs：呢 不知道为什么

问题在图片中，麻烦老师给看看。。。。。。。。。。。。。。

我网上查了说是one_hot编码有BUG，需要改到CPU上运行，但是我没找到老师的代码里有one_hot啊，怎么办

老师好：

笔记上写的是

db=pymysql.connect('localhost'.'root','root','testdb')

但是代码里给的是

con=pymysql.connect(=====)

请问这是两种不同的写法，都可以运行？还是按照代码给出的写法为准？

老师，我感觉这个进程池中的apply 同步运行这个‘同步’我还是不太懂，我感觉在用apply给进程池中的进程分任务的时候要等待这个进程执行完才能分配下一个任务，像是线程中的串联运行，但是这个‘同步’是指什么同步？

然后在用apply_async 变成了异步运行，实际上就是每个进程不等其他进程执行的怎么样了，只要进程池里还有进程就执行任务，这个‘异步’又是什么‘异步’呢？

老师，我有个小问题，我想试着用全局变量实现类似Manager在不同进程间通信的功能，但是即便我在另一个进程中global了一下，他还是不停报变量没有定义，所以我想问，是不是全局变量是不能在两个进程之间共享的？